示例说明

最近更新时间: 2026-03-13 09:03:00

示例编译运行

  1. Linux编译参考。
//编译
/usr/local/jdk/bin/javac -classpath kafka-clients-2.8.2.jar KafkaClientExample.java 
//打包
/usr/local/jdk/bin/jar -cvf KafkaClientExample.jar KafkaClientExample.class

//建议使用idea编译打包fat jar
//参考示例工程 kafka-examples/kafka-example 打包出 kafka-example-1.0-SNAPSHOT-jar-with-dependencies.jar
mvn clean package

  1. 测试运行。

//运行
/usr/local/jdk/bin/java -classpath kafka-example-1.0-SNAPSHOT-jar-with-dependencies.jar com.tencent.tbds.kafka.KafkaClientExample