kafka发送消息至指定分区_kafka 发送消息到指定分区

前言

在实际使用中，我们可能需要对某个topic下不同的消息进行分类管理，比如确保消费的顺序性，在这种场景下，我们可以首先确保生产者发送消息到指定的分区即可

本文的测试基于docker搭建的一个双节点的简单集群，有兴趣搭建的同学可参考我的另一篇博客

1、创建一个名为second的topic

在该topic下，有3个分区，两个副本

$KAFKA_HOME/bin/kafka-topics.sh --create --zookeeper zoo1:2181 --replication-factor 2 --partitions 3 --topic second
1

2、从某个docker节点下进入控制台，输入如下命令等待消费

$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server kafka1:9092 --from-beginning --topic second
1

在使用Java客户端连接kafka进行消息发送时，提供了2种发送消息到指定的分区的方式，下面分别进行演示

3、pom文件添加如下依赖

		<dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>0.11.0.0</version>
        </dependency>

1
2
3
4
5
6