首页  |  知识库  |  资源下载  |  在线工具  |  A-Z  •  JAR  •  名词查         

关于实现kafka-client客户端生产和消费消息的完整java示例项目源码下载(含依赖jar)

标签:kafka-clients-0.9.0.1.jar,kafka示例demo,Kafka消息者,KAFKA消费者,kafka依赖jar包,kafka客户端     发布时间:2019-03-25   

一、项目简介

该项目基于jdk1.8版本依赖kafka-clients-0.9.0.1.jar,实现对kafka消息订阅和产生 - 定义KafkaConsumerTest消息消费者测试类和KafkaProducerTest消息生产者测试类。

关于实现kafka的生产和消费消息的完整java示例项目源码下载(含依赖jar)

服务端安装版本说明>>@b@1) jdk1.7 (jdk-7u79-linux-x64.tar.gz)@b@2)安装kafka_2.11-0.9.0.1.tgz@b@3) zookeeper-3.4.6.tar.gz
kafka安装步骤参考  @b@配置注意点:@b@1)config/server.properties中@b@1.1 - listeners=PLAINTEXT://:9092改为具体地址listeners=PLAINTEXT://192.168.1.18:9092@b@1.2 - zookeeper.connect=localhost:2181  如zk不再本机,修改对应zk服务器ip,如改为zookeeper.connect=192.168.1.19:2181@b@2)config/ consumer.properties @b@2.1 - zookeeper.connect=127.0.0.1:2181 ,如zk不是本机地址i,修改对应zk服务器ip,如改为zookeeper.connect=192.168.1.19:2181@b@3)config/producer.properties@b@3.1 metadata.broker.list=localhost:9092  根据本地具体ip地址进行设置,如metadata.broker.list=192.168.1.18:9092

二、控制台结果

1. 运行KafkaConsumerTest消息消费者测试类

log4j:WARN No appenders could be found for logger (org.apache.kafka.clients.producer.ProducerConfig).@b@log4j:WARN Please initialize the log4j system properly.@b@key:1 value:1@b@key:2 value:2@b@key:3 value:3@b@key:4 value:4@b@key:5 value:5@b@key:6 value:6@b@key:7 value:7@b@key:8 value:8@b@key:9 value:9@b@key:10 value:10@b@key:11 value:11@b@key:12 value:12@b@key:13 value:13@b@key:14 value:14@b@key:15 value:15@b@key:16 value:16

2. 运行KafkaProducerTest消息生产者测试类

log4j:WARN No appenders could be found for logger (org.apache.kafka.clients.consumer.ConsumerConfig).@b@log4j:WARN Please initialize the log4j system properly.@b@offset = 68, key = key:1, value = value:1@b@offset = 69, key = key:2, value = value:2@b@offset = 70, key = key:3, value = value:3@b@offset = 71, key = key:4, value = value:4@b@offset = 72, key = key:5, value = value:5@b@offset = 73, key = key:6, value = value:6@b@offset = 74, key = key:7, value = value:7@b@offset = 75, key = key:8, value = value:8@b@offset = 76, key = key:9, value = value:9@b@offset = 77, key = key:10, value = value:10@b@offset = 78, key = key:11, value = value:11@b@offset = 79, key = key:12, value = value:12@b@offset = 80, key = key:13, value = value:13@b@offset = 81, key = key:14, value = value:14@b@offset = 82, key = key:15, value = value:15@b@offset = 83, key = key:16, value = value:16
  • 云盘下载:
  • [提取码:jgjr]
  • 本地下载:
  • ◆ 相关内容