我想知道是否可以仅在生产者部分使用EOS来配置KafkaStream配置。我有一个主题源,没有事务,也没有生产者设置的提交(生产者是一个还没有实现事务支持的librdkafka )。我想在这个主题上使用KafkaStream和EOS生产者(事务+提交),但我不认为这是可能的,因为这一部分:
final Map tempConsumerDefaultOverrides = new HashMap= Collections.unmodifiableMap(tempConsumerDefaultOverride