6.8基于java API方式使用 Kafka

 用户不仅能够通过命令行的形式操作Kafka服务,Kafka还提供了许多编程语言的客户端工具,用户在开发独立项目时,通过调用Kafka API来操作Kafka集群,其核心API主要有5种,分别是Producer API、Consumer API、Streams API、Connect API、AdminClient API。

  1. 创建一个名为“spark_chapter06”的Maven工程,在pom.xml文件中添加Kafka依赖。
  2. 创建KafkaProducerTest文件用于生产消息数据并将数据发送到Kafka集群。
  3. 通过Kafka API创建KafkaConsumer对象,用于消费Kafka集群中名为“itcasttopic”主题的消息数据。

最后修改: 2021年10月29日 星期五 12:44