时间戳

首页 > 解决方案 > CometD 和 Kafka 消费者

java - CometD 和 Kafka 消费者

问题描述

我正在尝试使用 kafka 实现 CometD 应用程序。

用例：到目前为止，我在向 Kafka Producer 发送消息时建立了一个 cometD 连接。我有一个 Servlet 侦听器来初始化 kafka 消费者并轮询来自主题的消息。我正在使用 ServerSession 将消息传递回客户端。当来自同一组的多个消费者轮询消息时，它可能会轮询针对另一个消费者的响应，该响应包含消息必须传递到的唯一 ID，但它可以找到它，因为会话 ID 存在于另一个消费者所在的另一个主机上在跑。谁能帮我理解我该如何处理这种情况

谢谢

标签： javaapache-kafkakafka-consumer-apicometd

解决方案

推荐阅读