小编Meg*_*gha的帖子

使用来自多个 kafka 主题的消息的最佳实践是什么?

我需要消费来自不同 kafka 主题的消息,

  1. 我是否应该为每个主题创建不同的消费者实例,然后根据分区数启动一个新的处理线程。或者
  2. 我应该从单个消费者实例订阅所有主题,并且应该启动不同的处理线程

谢谢和问候,梅加

multithreading apache-kafka kafka-consumer-api

5
推荐指数
1
解决办法
5500
查看次数

如何处理kafka KStream并直接写入数据库而不是发送另一个主题

我不想将已处理的KStream写入另一个主题,我直接想要将丰富的KStream写入数据库.我该怎么办?

apache-kafka apache-kafka-streams apache-kafka-connect

2
推荐指数
1
解决办法
2867
查看次数