Kafka_2.10-0.10.0.0- LEADER_NOT_AVAILABLE

雨点打透心脏的1/2处 2022-07-13 06:17 111阅读 0赞

环境准备：

1.Zookeeper分布式环境，连接字符串为master:2182,slave1:2182,slave2

2.Kafka Standalone环境, kafka安装于slave1。

Kafka配置：

1.connect-standalone.properties 中修改主机名localhost, bootstrap.servers=slave1:9092

2.producer.properties中修改主机名localhost, bootstrap.servers=slave1:9092

3.zookeeper.properties修改clientPort为2182

4.consumer.properties修改zookeeper连接字符串，zookeeper.connect=master:2182,slave1:2182,slave2:2182

5.server.properties

listeners=PLAINTEXT://slave1:9092  
\#host.name=slave1  
\#port=9092

advertised.listeners=PLAINTEXT://slave1:9092  
\#advertised.host.name=slave1  
\#advertised.port=9092

zookeeper.connect=master:2182,slave1:2182,slave2:2182

启动console-producer时，不停报LEADER\_NOT\_AVAILABLE错误，首先检查配置是否正确，其次有可能topic创建方式不对。

创建topic --> bin/kafka-topics.sh --create --zookeeper master:2182,slave1:2182,slave2:2182 --replication-factor 1 --partitions 1 --topic test

bin/kafka-topics.sh --list --zookeeper master:2182,slave1:2182,slave2:2182

生产bin/kafka-console-producer.sh --broker-list slave1:9092 --topic test1

消费bin/kafka-console-consumer.sh --zookeeper master:2182,slave1:2182,slave2:2182 --topic test1 --from-beginning

发表评论取消回复

表情：

评论列表（有 0 条评论，111人围观）

还没有评论，来说两句吧...

相关阅读

相关【Kafka】Docker安装kafka&java kafka api

内容目录一、安装zookeeper 1 拉取镜像 2 创建network 3 启动容器

Dear 丶/ 2023年10月12日 15:12/ 0 赞/ 113 阅读

相关 Kafka（七）------Kafka实战

1、概述消息生产者发送消息，消费消费者消费消息 ![在这里插入图片描述][20201111223651597.png_pic_center] 准备工作：kafak

àì夳堔傛蜴生んèń/ 2022年12月20日 11:15/ 0 赞/ 184 阅读

相关 Kafka教程,Kafka面试题,Kafka详解

【订阅[专栏合集][Link 1],作者所有付费文章都能看(持续更新)】推荐【Kafka教程】[https://bigbird.blog.csdn.net/article/

桃扇骨/ 2022年12月10日 07:04/ 0 赞/ 208 阅读

相关 Kafka工具--Kafka Tool

原文网址：[Kafka工具--Kafka Tool\_IT利刃出鞘的博客-CSDN博客][Kafka_--Kafka Tool_IT_-CSDN] 其他网址 [kafk

川长思鸟来/ 2022年10月29日 12:28/ 0 赞/ 387 阅读

相关 kafka 监控 kafka eagle

官方文档： http://www.kafka-eagle.org/articles/docs/installation/linux-macos.html 下载Kafka

Love The Way You Lie/ 2022年10月23日 08:05/ 0 赞/ 220 阅读

相关 Kafka（一）： Kafka 入门

一．Kafka 简介 Kafka是一种

亦凉/ 2022年06月16日 11:08/ 0 赞/ 296 阅读

相关【Kafka】深入了解kafka

背景介绍 Kafka简介 Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下：以时间复杂度为O(1)的方式提供消息持久化能力

比眉伴天荒/ 2022年06月15日 11:58/ 0 赞/ 209 阅读

相关 [Kafka]为什么使用kafka?

在介绍为什么使用kafka之前，我们有必要来了解一下什么是kafka？ 1. 什么是kafka？ Kafka是由LinkedIn开发的一个分布式的消息系统，使用Scal

小咪咪/ 2022年06月06日 12:13/ 0 赞/ 247 阅读

相关 kafka-01 Kafka简介

![70][] Kafka是一种高吞吐量的[分布式][Link 1]发布订阅消息系统，使用Scala编写。对于熟悉JMS（Java Message Servic

柔光的暖阳◎/ 2022年05月16日 23:19/ 0 赞/ 300 阅读

相关 FlinkSQL Kafka to Kafka

[Apache Kafka SQL Connector][] FlinkSql 读 Kafka import org.apache.flink.streami

朴灿烈づ我的快乐病毒、/ 2021年09月24日 14:30/ 0 赞/ 407 阅读