Kafka流:在不覆盖两个值的情况下配置‘`AdminClientConfig`’或‘`ConsumerConfig`’

Question

使用kafka版本: 2.0.1和kafka-streams-scala版本2.0.1

记录调试消息，例如：

调试2019年-05-08:57:53,322 he.kafka.clients.NetworkClient :使用者groupId=XXX因请求超时而与节点YYY断开连接。

导致我增加了request.timeout.ms值：

  private val config: Properties = new Properties
  config.put(StreamsConfig.REQUEST_TIMEOUT_MS_CONFIG, "240000")
...
  private val streams: KafkaStreams = new KafkaStreams(topology, config)

但是，这将AdminClientConfig和ConsumerConfig的新值设置为2400 to ( AdminClientConfig和ConsumerConfig的默认request.timeout.ms值实际上不同--分别为- 120000ms和40000ms )。

有没有办法在不覆盖两个值的情况下为AdminClientConfig或ConsumerConfig设置Kafka流配置值？

Answer 1

您可以用consumer.或admin.作为任何配置的前缀，以便只将其应用于一个客户端。

还有main.consumer.，restore.consumer.和global.consumer.来进一步区分不同的消费者。使用consumer.作为前缀，配置将应用于所有使用者。

最后，还有producer.前缀(只需提及它的完整性)。

比较文档：https://docs.confluent.io/current/streams/developer-guide/config-streams.html#naming