关于kafka配置 启动 报错 处理_kafka启动报错

1.kafka配置

在kafka_2.13-2.8.2\conf 中修改两个文件 zookeeper.properties  server.properties

zookeeper.properties

 zookeeper默认配置linux系统目录，在windows中启动需要修改自己创建的路径

server.properties也是如此

 2.启动kafka

通过命令进入kafka_2.13-2.8.2的bin目录下的windows目录

 目录为  D:\javaweb\kafka\kafka_2.13-2.8.2

启动zookeeper 

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

然后在开一个命令行启动kafka

 

 

 命令为 bin\windows\kafka-server-start.bat config\server.properties

在此过程中kafka可能会报错

 而我们只需要在我们创建的kafkadata的文件中kafka-logs里相应的日志删除即可

上面的错误我们只需要删除kafka-logs中的48日志即可

3.

    1)另开一个命令行开启生产者模式

创建生产者 kafka-topics.bat --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

显示所有主题 kafka-topics.bat --list --bootstrap-server localhost:9092

生产者开始发送消息 kafka-console-producer.bat --broker-list localhost:9092 --topic test

    2)再开一个命令行

创建消费者 kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test--from-beginning   直接运行