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

Question

我正在使用 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 数据包详细信息？

Answer 1

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

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