使用 KStream 实现,我应该设置 ProducerConfig 还是 StreamsConfig 设置?
With KStream implementation, should I set ProducerConfig or StreamsConfig settings?
我有一个 KStream 实现,我看到 ProducerConfig 和 StreamsConfig 都有类似的设置,例如 REQUEST_TIMEOUT_MS_CONFIG。
我应该同时设置两者吗?
如果不是,是哪一个?
它们的计算结果相同(连同 ConsumerConfig 属性)。如果您同时设置两者,则后一个会覆盖第一个,因为这就是 Java 地图和属性的工作方式。
如果您在编写 Kafka Streams 作业时坚持使用 StreamsConfig 常量,通常更容易阅读您的代码
我有一个 KStream 实现,我看到 ProducerConfig 和 StreamsConfig 都有类似的设置,例如 REQUEST_TIMEOUT_MS_CONFIG。
我应该同时设置两者吗?
如果不是,是哪一个?
它们的计算结果相同(连同 ConsumerConfig 属性)。如果您同时设置两者,则后一个会覆盖第一个,因为这就是 Java 地图和属性的工作方式。
如果您在编写 Kafka Streams 作业时坚持使用 StreamsConfig 常量,通常更容易阅读您的代码