tcp - 如何查看 Apache Kafka 生成的完整 TCP 数据包?

标签 tcp apache-kafka

我正在使用 Apache Kafka。我使用 KafkaProducer 生成数据,使用 KafkaConsumer 消费数据。我的配置数据是:

Properties props = new Properties();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
props.put(ProducerConfig.CLIENT_ID_CONFIG, "DemoProducer");
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.IntegerSerializer");
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");

消费者配置相同。如何查看生产者和消费者正在发送和接收的整个 TCP 数据包详细信息?

最佳答案

安装 Wireshark 后,您必须转到 Edit->Prefrences 或按 Ctrl + Shift + P。在新窗口中打开 protocols 树并在列表中找到 Kafka。选择 Kafka 后,您必须设置 Kafka broker 端口号(默认为 9092)。并且还要选中 Show length for string and bytes fields in the protocol tree 复选框,如爆炸图像所示:

enter image description here

然后单击“确定”关闭窗口。然后您可以查看所有 Kafka API 调用:

enter image description here

关于tcp - 如何查看 Apache Kafka 生成的完整 TCP 数据包?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38352631/

相关文章:

c - 如何使用 C 中的 ctime() 从套接字读取字节

c# - 哪个 .Net 组件应该用于 tcp/ip 套接字通信?

apache-spark - 卡夫卡+ Spark 流: ClosedChannelException

java - 从一系列偏移量之间的 Kafka 主题读取消息

java - 缺少来自套接字的数据

python - 从套接字数据转换为numpy数组

java - 以编程方式写入 AWS S3 - 返回 - root 帐户不能承担角色。

apache-kafka - 在 kafka 中获取当前配置

java - 我应该在哪里创建 Akka Actor 中的 Kafka 消费者?

http - panic : close of closed channel during persistent http call in GO(golang)