java - 如何取回 Kafka 生产者和消费者配置(Java API)?

标签 java api apache-kafka kafka-consumer-api kafka-producer-api

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

那么,如何返回Kafka生产者和消费者的配置呢?

最佳答案

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

关于java - 如何取回 Kafka 生产者和消费者配置(Java API)?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47671049/

相关文章:

api - 是否可以通过服务器端API将事件发布到Google Analytics(分析)?

ruby-on-rails - 具有相同数据库的两个 Rails 应用程序?

apache-kafka - 在 Windows 机器上设置并运行 KSQL

java - Kafka 使用 Sink Connector 进行 google Pub/Sub

java - 如果我本地没有 sbt,我可以使用 yahoo-kafka-manager 吗?

用于图的集团覆盖的 Java 库

java - Jackson 序列化 null 或空对象

java - 递归调用占用内存

java - 放心承载认证

java - 显式指定用于读取 JSON 的架构并将缺失的字段标记为 null