两个kafka组成集群，往里面写数据，但是消费者不去读取数据，为什么？

来源：5-5 Kafka多Broker部署及使用

fuyang7412

2022-10-28

两个kafka集群，配置如下：
【server01.properties】
broker.id=1
listeners=hadoop000://:9093
log.dirs=/hadoop/app/tmp/kafka-logs01
【server02.properties】
broker.id=2
listeners=hadoop000://:9094
log.dirs=/hadoop/app/tmp/kafka-logs02

创建topic：
bin/kafka-topics.sh --create --bootstrap-server hadoop000:9093,hadoop000:9094 --replication-factor 2 --partitions 1 --topic Demo

生产者：
图片描述

消费者，不读取数据：
图片描述

写回答

2回答

酱汁怪兽

2022-11-16

总体来看，流程是对的。

具体差异点在于：

1、kafka集群的配置。

2、创建topic。

示例：

1、kafka集群的配置：

[root@Server-i-mi2fz66jb6 config]# pwd
/home/hadoop/app/kafka_2.12-2.5.0/config
[root@Server-i-mi2fz66jb6 config]# cp server.properties server-local-test1.properties
[root@Server-i-mi2fz66jb6 config]# cp server.properties server-local-test2.properties
[root@Server-i-mi2fz66jb6 config]# cp server.properties server-local-test3.properties

////修改properties配置文件，否则会冲
///---指定唯一id
///---修改kafka端口
///---修改log目录
[root@Server-i-mi2fz66jb6 config]# pwd
/home/hadoop/app/kafka_2.12-2.5.0/config
[root@Server-i-mi2fz66jb6 config]# vi server-local-test1.properties
############################# Server Basics ##########################


broker.id=0
############################# Socket Server Settings #################
# 允许外部端口连接  
listeners=PLAINTEXT://0.0.0.0:9092
# 外部代理地址                                                
advertised.listeners=PLAINTEXT://192.168.50.66:9092

############################# Log Basics #############################
log.dirs=/home/hadoop/app/tmp/kafka-logs-0


[root@Server-i-mi2fz66jb6 config]# vi server-local-test2.properties
############################# Server Basics ##########################


broker.id=1
############################# Socket Server Settings #################
listeners=PLAINTEXT://0.0.0.0:9093
advertised.listeners=PLAINTEXT://192.168.50.66:9093

############################# Log Basics #############################
log.dirs=/home/hadoop/app/tmp/kafka-logs-1


[root@Server-i-mi2fz66jb6 config]# vi server-local-test3.properties
############################# Server Basics ##########################


broker.id=2
############################# Socket Server Settings #################
listeners=PLAINTEXT://0.0.0.0:9094
advertised.listeners=PLAINTEXT://192.168.50.66:9094

############################# Log Basics #############################
log.dirs=/home/hadoop/app/tmp/kafka-logs-2

2、创建topic

[root@Server-i-mi2fz66jb6 config]# pwd
/home/hadoop/app/kafka_2.12-2.5.0/config
[root@Server-i-mi2fz66jb6 config]# kafka-topics.sh --create --bootstrap-server hadoop000:9092,hadoop000:9093,hadoop000:9094 --replication-factor 3 --partitions 1 --topic localtest-replicated-topic

先看看是否能纠正。