Leader不可用Kafka在控制台Producer中
我正在尝试使用Kafka。
所有配置都已正确完成，但当我尝试从控制台生成消息时，我一直得到以下错误
WARN Error while fetching metadata with correlation id 39 :
{4-3-16-topic1=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
Kafka版本:2.11-0.9.0.0
共有1个答案
它可能与server.properties中的adversed.host.name设置有关。
可能发生的情况是，您的生产者试图找出给定分区的领导者，找出其advertised.host.name和advertised.port并尝试连接。如果没有正确配置这些设置，那么它可能会认为leader不可用。
-
java 我正在使用控制中心来检查这个主题的消费者，并跟踪正在消费的数据。在运行这个应用程序时，它与Kafka和所有分区都连接得很好，我可以在控制中心看到所有的数据都被提取了，但在我的java控制台中没有打印任何数据。但是我注意到，在向Kafka发送一些新数据时，它会在java控制台中打印出来（即，在运行我的消费者后将新数据发送给Kafka）。它应该是这样的吗？还是我做错了什么？根据我的理解，Ka
-
我试图使用apache kafka二进制文件中的kafka控制台生成器生成消息，并在spring boot中使用消费者设置。消费者使用avro模式。 当消息以json格式生成时，我的消费者抛出异常-“无法序列化”。 我找到了一个解决方案，可以使用“ConFluent Platform 7.1”，它有kafka-avro-console-生产者。它支持avro，但它是企业版。 有没有一种方法可以使用
-
以下代码在PowerShell ISE中工作，但在常规PowerShell控制台中运行时，文档对象为空： 电源外壳 ISE 中的输出： 常规电源外壳控制台中的输出： 在PowerShell中运行时。exe、和的所有其他属性均为空。为什么会这样？如何修复？谢谢
-
我有一个基于java的web应用程序的kafka生产者，可以将消息推送到kafka。根据文档，我可以看到kafka生产者是线程安全的。这是否意味着我可以拥有Kafka生产者的单个实例，并由不同的线程（web请求）使用，在我的情况下，每个线程都将打开和关闭生产者。这会产生任何问题吗？还是根据请求启动生产者更好？
-
问题内容： 我希望这不是重复的。 我试图用来在单独的控制台中打开脚本。我尝试设置参数，但是没有成功。 我在64位Windows 7上使用32位Python 2.7。 问题答案： 如果不使用，则必须提供列表而不是命令字符串，例如： 然后将其打开而没有外壳。 这是您可以从Python调用子流程的最手动，最灵活的方式。如果只需要输出，请执行以下操作：
-
问题内容： 嗨，我在使用sql查询时遇到问题，它在控制台中可以完美地工作，但是当我在python中实现时，它似乎可以完美地工作，但是没有错误，但是当我检查数据库时，它没有起作用，但是在控制台中，它确实可以工作，但是没有错误。我检查数据库中的数据是否存在…我使用的查询完全相同。 有任何想法吗？ 在python中： 查询在打印中显示良好，没有问题，如果我将打印内容复制并粘贴到mysql控制台中，则每次