如何找回Kafka生产者和消费者配置(Java API)？

Question

用例如下.我在Java代码中通过许多对象实例传递生产者或消费者引用.在其中一些我想对Kafka配置进行一些检查.这意味着我想回来,Kafka Producer/Consumer中存储了哪些有效的配置(包括默认值).我没有看到java docs中的anthing:

• KafkaProducer
• KafkaConsumer

那么,如何找回 Kafka生产者和消费者配置呢？

Answer 1

不幸的是，这是不可能的。我不得不承认，这可能是一个有用的功能，至少可以显示“核心”配置属性（例如，避免获取身份验证内容的“秘密”的可能性）。我今天为您看到的唯一解决方案是在消费者/生产者实例和用于设置客户端配置的相关属性包之间建立链接。我知道这是浪费内存，因为这样的配置在客户端内部，但你需要保留你的属性包才能拥有它。