本文概览:介绍了使用java client api来发送消息和消费消息。

1 Maven配置

2 生产者

2.1 代码

生产者创建和生产消息代码如下:

 

 

3 消费者

3.1 代码

创建消费者代码和获取消息的逻辑如下:

 

4 测试

执行结果为:

5 参考资料

https://www.tutorialspoint.com/apache_kafka/apache_kafka_simple_producer_example.htm

 

分类&标签