apache-kafka - 从主题中的特定分区流式传输(Kafka Streams)

标签 apache-kafka apache-kafka-streams

据我阅读 Kafka Streams 文档后的理解,不可能将它用于仅来自给定主题的一个分区的流数据,人们总是必须完整阅读它。

那是对的吗?

如果是这样,将来是否有计划为 API 提供这样的选项?

最佳答案

不,您不能这样做,因为内部使用者订阅了加入通过 application-id 指定的使用者组的主题,因此会自动分配分区。
顺便说一句,你为什么要这样做?
如果不重新平衡,您将失去 Kafka Stream 提供的可扩展性功能,因为只需添加/删除流应用程序的实例,您就可以扩展整个过程,这要归功于分区上的重新平衡。

关于apache-kafka - 从主题中的特定分区流式传输(Kafka Streams),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44657521/

相关文章:

java - 客户端健康检查 : Check for consumer/producer if broker is down

java - 如何重命名Kafka主题

apache-kafka - Kafka Streams - kafka-streams-application-reset.sh 发送错误的 API 版本

java - 卡夫卡流 RoundRobinPartitioner

java - Kafka Streams 在多个流中拆分 1 个流

java - 如何在java中的kafka中获取消费者组的消费者滞后

java - 卡夫卡消费者没有收到旧消息

apache-kafka - Kafka 消费者 - 民意调查行为

go - 使用 sarama 编写 Kafka 制作人时无效的时间戳

apache-kafka - 为什么我必须使用 Kafka Streams 配置状态存储