【发布时间】:2015-05-22 04:29:11
【问题描述】:
我有多个主题,并且来自每个主题的消息具有不同的行为。所以我必须以不同的方式处理每条消息。因此,我将消息及其主题与 Kafka 流区分开来。有什么解决方案吗?我希望以代码 sn-p 为例。感谢您的任何建议。
【问题讨论】:
标签: apache-kafka consumer kafka-consumer-api
我有多个主题,并且来自每个主题的消息具有不同的行为。所以我必须以不同的方式处理每条消息。因此,我将消息及其主题与 Kafka 流区分开来。有什么解决方案吗?我希望以代码 sn-p 为例。感谢您的任何建议。
【问题讨论】:
标签: apache-kafka consumer kafka-consumer-api
如果您只想从不同的 kafka 主题中消费,只需选择 Consumer group or High Level consumer .. 您可以为每个主题运行不同的消费者组
【讨论】: