6.8基于java API方式使用 Kafka
用户不仅能够通过命令行的形式操作Kafka服务,Kafka还提供了许多编程语言的客户端工具,用户在开发独立项目时,通过调用Kafka API来操作Kafka集群,其核心API主要有5种,分别是Producer API、Consumer API、Streams API、Connect API、AdminClient API。
- 创建一个名为“spark_chapter06”的Maven工程,在pom.xml文件中添加Kafka依赖。
- 创建KafkaProducerTest文件用于生产消息数据并将数据发送到Kafka集群。
- 通过Kafka API创建KafkaConsumer对象,用于消费Kafka集群中名为“itcasttopic”主题的消息数据。
Last modified: Friday, 29 October 2021, 12:44 PM