kafka入门教程，介绍全面-Toy模板网

kafka入门教程，介绍全面

8月前作者：香至-人生万事须自为，跬步江山即寥廓。分类：Toy博客阅读(29) 违法举报

这篇具有很好参考价值的文章主要介绍了kafka入门教程，介绍全面。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

1、官网下载最新版本的kafka，里面已经集成zookeeper。直接解压到D盘

2、配置文件修改，config目录下面的zookeeper.properties. 设置zookeeper数据目录

dataDir=D:/kafka_2.12-3.6.0/tmp/zookeeper

kafka入门教程，介绍全面,kafka,分布式

3、修改kafka的配置文件server.properties. 主要修改内容如下：

zookeeper.connect=localhost:2181

log.dirs=D:\\kafka_2.12-3.6.0\\logs

listeners=PLAINTEXT://localhost:9092

其他默认即可。

4、修改完成后进入bin目录：启动zookeeper和kafka，命令如下

zookeeper-server-start.bat ../../config/zookeeper.properties

kafka-server-start.bat ../../config/server.properties

5、命令行创建topic，命令如下：

kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic hello

6、创建生产者和消费者，测试。生产者输入消息，消费者就会收到相应的消息了

kafka-console-producer.bat --broker-list localhost:9092 --topic hello

kafka入门教程，介绍全面,kafka,分布式

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic hello--from-beginning

kafka入门教程，介绍全面,kafka,分布式

7、创建springboot工程，测试

引入依赖：

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
</dependency>

8、yml文件配置kafka

spring:
kafka:
bootstrap-servers: localhost:9092
producer:
acks: 1
retries: 3
batch-size: 16384
properties:
linger:
ms: 0
buffer-memory: 33554432
key-serializer: org.apache.kafka.common.serialization.StringSerializer
value-serializer: org.apache.kafka.common.serialization.StringSerializer
consumer:
group-id: helloGroup
enable-auto-commit: false
auto-commit-interval: 1000
auto-offset-reset: latest
properties:
request:
timeout:
ms: 18000
session:
timeout:
ms: 12000
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

9、使用springboot KafkaTemplate发送消息

@RequestMapping(value = "/sendMessage", method = RequestMethod.GET)
public String sendMessage(String message) {
kafkaTemplate.send("hello", message);

return "发送成功~";
}

10、消息消费，

@KafkaListener(topics = "hello")
public void receiveMessage(ConsumerRecord<String, String> record) {
String topic = record.topic();
long offset = record.offset();
int partition = record.partition();
String message = record.value();

System.out.println("topic = " + topic);
System.out.println("offset = " + offset);
System.out.println("partition = " + partition);
System.out.println("message = " + message);
}文章来源地址https://www.toymoban.com/news/detail-744934.html

到了这里，关于kafka入门教程，介绍全面的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！