apache-kafka - Apache kafka中的相关ID

标签 apache-kafka

是否有基于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.

https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-Requests

关于apache-kafka - Apache kafka中的相关ID,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23760587/

相关文章:

java - 如何将 SMT 应用于 Kafka Connect 中的单个主题?

python - 如何以编程方式更新 Confluent Schema Registry 中的主题架构和兼容性

memory - 随着时间的推移,KTable/KStream 内存消耗

java - Apache Storm Kafka Spout 延迟问题

java - 从Consumer端创建主题

apache-spark - Spark 流 DirectKafkaInputDStream : kafka data source can easily stress the driver node

java - 使用kafka的双向消息系统

python - 为什么kafka生产者向我显示错误kafka.conn:<容器ID>:9092的DNS查找失败?

java - Kafka : Single consumer group, 无分区和多个主题

amazon-s3 - 如何使用 Kafka S3 Sink Connector 中的 FieldPartitioner 创建分区