apache-kafka - Kafka Broker - 和 Zookeeper 一样吗?还是 KafkaProducer 是经纪人?
问题描述
有多个代码示例可用(其中一个是这里),其中实现了 KafkaProducer 和 KafkaConsumers,并且可以单独启动。
我试图找到启动代理的代码?
我认为 Zookeeper 不是 KafkaBroker,因为 Zookeeper 是出于其他目的......管理集群状态。
在创建 KafkaProducer 时,我们传入如下属性
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, IKafkaConstants.KAFKA_BROKERS);
这是否意味着 KafkaProducer 会自行启动代理?
解决方案
Zookeeper 管理 Kafka 代理的协调和同步,它们是独立的组件。
生产者不启动代理。Producer 和 Consumer 是客户端组件,它们连接到一个或多个 Kafka 代理,并在代理集群中生产/消费数据。
Kafka 代理通常通过运行kafka/bin/kafka-server-start.sh kafka/config/server.properties
来启动,它将启动一个具有server.properties
文件中定义的属性的 Kafka 代理。
推荐阅读
- python - 在 Pandas 数据框中识别两个 ID 列中的多对多连接?
- java - 使用 Java 从 Android 向 Web 服务器发送和接收数据(POST 和 GET)的最佳方式?
- tensorflow - 修剪和训练——它们如何在 TensorFlow 中协同工作?
- powerbi - 如何查找引用多个表的网络工作日
- node.js - 使用nodejs fetch和form-data时获取报告invalid_arg_type
- kotlin - 如何在使用 kotlinx.serialization 时为接口注册全局类型适配器,而不用注释每个类?
- python - 从二维单元格numpy数组中获取邻接矩阵的最佳方法
- performance - 旧版 Rails 应用程序升级到 6.0.4 导致响应速度大幅下降
- android - Android x86 更改键盘布局
- rest - 通过从文件中读取一次将环境变量存储为全局变量是否可以?