我正在尝试用kafka实现一个cometd应用程序。
用例：我在向kafka producer发送它发布的消息时建立了一个Comed连接。我有一个servlet监听器来初始化kafka消费者并轮询来自某个主题的消息。我正在使用serversession将消息传递回客户端。当来自同一组的多个使用者轮询消息时，它可能会轮询针对另一个使用者的响应，该响应包含消息必须传递到的唯一id，但它可能会找到它，因为会话id存在于另一个使用者正在运行的另一个主机上。有人能帮我理解我该如何处理这种情况吗
谢谢