生成Kafka消息到选定的分区

 arliejun 发布于 2022-12-15 14:45

根据Kafka文件:

生产者负责选择将哪个消息分配给主题中的哪个分区.

因此我的主要问题是:

如何使用kafka-console-producer.sh(或Kafka Java客户端)将消息发送到所选分区?

我想在消息发送时指定某种"分区ID".可能这样的"分区ID"存储在Zookeeper中的某个地方.你知道哪一个值(在Zookeeper中)识别Kafka分区吗?

撰写答案
今天,你开发时遇到什么问题呢?
立即提问
热门标签
PHP1.CN | 中国最专业的PHP中文社区 | PNG素材下载 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有