Kafka producer无法通过Bootstrap服务器生成消息。如何设置broker主机？
Kafka producer无法通过Bootstrap服务器生成消息的原因可能是未正确设置broker主机。要设置broker主机，可以按照以下步骤进行操作：
- 首先，确保你已经安装并配置了Kafka。可以参考Kafka官方文档或相关教程进行安装和配置。
- 打开Kafka的配置文件，通常是
server.properties，可以在Kafka安装目录下找到。 - 在配置文件中找到并编辑以下属性：
advertised.listeners：这个属性定义了Kafka broker对外部客户端的监听地址。可以设置为PLAINTEXT://<broker主机名>:<端口号>。例如，PLAINTEXT://kafka.example.com:9092。listeners：这个属性定义了Kafka broker监听的地址。可以设置为PLAINTEXT://<broker主机名>:<端口号>。例如，PLAINTEXT://kafka.example.com:9092。host.name：这个属性定义了Kafka broker所在的主机名。可以设置为<broker主机名>。例如，kafka.example.com。port：这个属性定义了Kafka broker监听的端口号。可以设置为一个未被占用的端口号。例如，9092。
- 保存并关闭配置文件。
- 重启Kafka服务，使配置生效。
设置完broker主机后，确保你的Kafka producer代码中使用了正确的Bootstrap服务器地址，即<broker主机名>:<端口号>。例如，kafka.example.com:9092。
如果以上步骤正确执行，你的Kafka producer应该能够通过Bootstrap服务器生成消息了。
关于腾讯云相关产品，腾讯云提供了消息队列 CKafka 服务，可以用于构建高可用、高吞吐量的消息系统。你可以参考腾讯云CKafka的产品介绍和文档来了解更多信息：
相关·内容
Kafka Producer API超时异常。手动生成Kafka消息的过程 我们通过SSH连接到kafka Server: x.x，在那里我们为生产者输入以下命令 /kafka/bin/kafka-console-producer.sh --brokerBrokerHostAddress:9092 --topic TestTopic
{ValidJsonData} <e
浏览 18提问于2019-01-31得票数 0
1回答
我无法通过代码连接到本地运行的Kafka实例-我可以使用Kafka-Console-Producer和Kafka-Console-Consumer成功连接，但当我使用Kafka Java SDK并简单地使用Java Producer连接并生成任何消息时，会失败，并显示以下错误：
[Producer clientId=producer-1] Connection to node -1
浏览 468提问于2020-05-25得票数 2
回答已采纳
= new KafkaProducer<String, String>(props);我可以在卡夫卡码头容器内外通过bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic
浏览 2提问于2018-01-25得票数 0
producer.properties中，我有bootstrap.servers=0.0.0.0:9092在EC2中，启动了kafka 'confluent start'并创建了“mytopic”
我在本地机器上运行的producer.py代码看起来像这样(相关部分)：from confl
浏览 0提问于2018-10-11得票数 1
3回答
kafka-console-consumer.bat --bootstrap-server localhost:2181 --topic baeldung kafka-console-producer.bat--broker-list localhost:9092 --topic baeldung
消息不会从生产者传递到消费者。
浏览 0提问于2018-12-20得票数 1
假设有以下场景：
我在本地启动zookeeper和一个kafka代理，并创建“测试”主题，如kafka快速入门：中所述。然后，我运行一个简单的java程序，该程序每秒生成一条指向"test“主题的消息。一段时间后，我关闭了我的本地kafka代理，看到producer继续生成消息，它没有抛出任何异常。最后，我再次启动kafka broker，producer能够重新连接到broker
浏览 1提问于2018-04-06得票数 1
1回答
下面是我的Kafka代理配置port=9092advertised.listeners=PLAINTEXT://127.0.0.1:9092但是Kafka broker正在运行，并且能够通过控制台生成和消费消息。[kafka-producer-network-thread | producer-1] WARN org.apache
浏览 9提问于2022-03-18得票数 0
(1)在localhost上，我运行：
主控台kafka_2.11-0.10.0.0bin/kafka-➜-Producer.sh --broker-list 192.168.1.110:9092 --topic test这是一条消息2016-08-24 18:15:27,441向topic test发送消息时出错: null，value: 2字节错误:包含1条记录的(org.apache.kafka.clients.producer.int
浏览 13提问于2016-08-24得票数 0
2回答
我正在使用kafka-python为Kafka 2.2.1集群(来自AWS的MSK服务的托管集群实例)生成消息。我能够检索引导服务器并建立到它们的网络连接，但是任何消息都无法通过。然而，它是由Amazon的(MSK) servive管理的，这意味着我对服务器安装设置没有细粒度的控制(甚至不知道它们是什么)。MSK只是发布动物园管理员和供客户使用。我可以用标准的telnet访问动物园管理员和消息代理的
浏览 8提问于2019-11-19得票数 8
回答已采纳
我正在使用mac并通过安装zookeeper和kafka通过使用以下命令：但是，connector显示以下消息，例如
[2020-08-05 09:53:40,222]Broker m
浏览 3提问于2020-08-05得票数 0
1回答
我已经设置了一个堡垒来连接到这个集群，并且可以使用kafka控制台命令和使用用于SSL auth的JVM密钥存储成功地从这个堡垒生成和使用消息。我正在尝试通过我的mac ->堡垒-> kafka代理的SSH隧道来生成/消费消息，但我似乎无法让它正常工作。N ec2-user@ec2-myhost.compute.amazonaws.com -L 9094:kafkacluster.amazonaws.com:90
浏览 1提问于2020-06-05得票数 0
1回答
/kafka-console-producer.sh --broker-list targetHost:port --topic test --producer.config /path/to/client.properties/path/to/jaas.conf -Djava.security.krb5.conf=/path/to/krb5.conf"
以下是client.properties设置</em
浏览 2提问于2020-01-29得票数 2
我的问题是:我如何将数据从kafka生产者发送到broker？下面的模式解释了我的网络配置：我使用kafka控制台测试：
bin/kafka-console-producer.sh--broker</em
浏览 1提问于2016-06-02得票数 0
我在我的服务器上有一个zookeeper/kafka设置，它工作得很好。一个人可以生产和消费
bin/kafka-console-consumer.sh--bootstrap-server 192.168.2.80:9092 --topic test --from-begi
浏览 3提问于2017-06-05得票数 11
我已经为kafka构建了一个docker镜像(wurstmeister/kafka-docker)。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用托管在上的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么也不会发生，程序就会卡住。我猜producer.send无法连接到kafka broker。
浏览 2提问于2017-02-03得票数 1
TutorialTopicecho "Hello, World" | ~/kafka/bin/kafka-console-producer.sh --broker-listlocalhost:9092 --topic TutorialTopic~/kafka/bin/kafka-cons
浏览 2提问于2021-06-09得票数 1
回答已采纳
13回答
在用kafka生成消息时，我得到了以下错误：
$ bin/kafka-console-producer.sh --broker-list localhost:9092 --topic nil_PF1_P1Error when sending message to topic nil_PF1_P1 with key: null, value: 2 bytes with error: (org.apache.kafka.clients.producer</
浏览 18提问于2016-07-19得票数 36
回答已采纳
2回答
我正在尝试用设置一个简单的Kafka应用程序。我一直在尝试让我在网上找到的一些例子起作用，但似乎无法做到。我有一个运行在docker容器中的kafka实例。我测试了shell工具，实例确实工作正常。我能够发送和接收消息。我怀疑生产者消息超时了。下面是代码的两个版本，它们的行为基本相同：from kafka import SimpleProducer, KafkaClientka
浏览 21提问于2017-07-09得票数 3
然而，当我设置一个控制台生产者时，我可以通过同一个代理进行生产和消费。admin.enableServer=false
运行这两个命令可以设置可以通过kafka发送消息的使用者/生产者。clientId=producer-1] Bootstrap broker localhost:
浏览 1提问于2020-09-16得票数 0
回答已采纳
2回答
我正在使用hortonwork Sandbox for kafka服务器，试图用java代码连接eclipse中的kafka。使用此配置连接到生产者以发送消息serializer.class=kafka.serializer.DefaultEncoderzk.connect=sandbox.hortonworks.com:2181<em
浏览 1提问于2015-03-20得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
