无论如何,基于correlationID(类似于JMS规范中的那个)在kafka中接收消息.我想创建一组听取同一主题但具有不同相关ID的消费者？
correlationId是每个TCP连接工件,允许客户端(生产者或消费者)将代理的响应映射到客户端的先前请求,它在该特定TCP连接之外没有任何意义.
CorrelationId - 这是用户提供的整数.它将在服务器的响应中传回,不加修改.它对于匹配客户端和服务器之间的请求和响应很有用.
| 归档时间： |
|
| 查看次数： |
7531 次 |
| 最近记录： |