如何查看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

你可以使用tshark與Kafka解剖器已經可用。

sudo apt-get update 
sudo apt-get install tshark 
sudo tshark -V -i lo -o 'kafka.tcp.port:9092' -d tcp.port=9092,kafka -f 'dst port 9092' 

這裏Using the kafka dissector in wireshark/tshark 1.12