kafka客户端可以扮演消费者和生产者的多重角色吗

Question

我创建了一个场景，其中具有生产者角色的客户端在 kafka 集群中的主题中发布消息，而具有消费者角色的客户端订阅该主题并从日志中轮询消息。我的问题是，如果在此之后具有消费者角色的客户端也是一个进程（例如数据库处理）并且他想要发回一些数据，那么它必须扮演生产者角色，而另一个客户端从之前的生产者角色变成消费者。客户是否可以同时扮演消费者和生产者的角色？有其他解决方案吗？

Answer 1

绝对地。没有理由不能在同一个客户端中实例化消费者和生产者。您可能想查看Kafka Streams，它的作用完全相同。