是否有基于correlationID(类似于JMS规范中的那个)在kafka中接收消息。我想创建一组从同一主题但具有不同相关 ID 的消费者?
最佳答案
correlationId 是每个 TCP 连接的工件,它允许客户端(生产者或消费者)将来自代理的响应映射到客户端的先前请求,它在该特定 TCP 连接之外没有任何意义。
CorrelationId - This is a user-supplied integer. It will be passed back in the response by the server, unmodified. It is useful for matching request and response between the client and server.
关于apache-kafka - Apache kafka中的相关ID,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23760587/