当前位置: 首页 > 知识库问答 >
问题:

Linux生产者到windows使用者无法解析

裴甫
2023-03-14
IP:192.168.0.149
hostname:something

第二台运行linux或windows的机器(双引导),带有生成程序:

IP:192.168.0.150
hostame:somethingelse

在server.properties上尝试了一些配置:

1 listeners=plaintext:\0.0.0.0:9092已播发。listeners=plaintext:\something:9092

producer = KafkaProducer(bootstrap_servers=['192.168.0.149:9092'])

第二台机器上的生产者:

producer = KafkaProducer(bootstrap_servers=['192.168.0.149:9092'])

在windows上工作,在linux上不工作

3#Listeners=#Advertised.Listeners=

producer = KafkaProducer(bootstrap_servers=['192.168.0.149:9092'])

4 listeners=plaintext:\192.168.0.149:9092已通告。listeners=plaintext:\something:9092

第二台机器上的生产者:

producer = KafkaProducer(bootstrap_servers=['192.168.0.149:9092'])

如果使用者传递ip而不是localhost,则在windows上工作,在linux上不工作

共有1个答案

弓宏茂
2023-03-14

监听器应始终保持0.0.0.0。这是接受所有外部连接的绑定地址

如果你想在windows上运行Kafka,你需要处理windows防火墙。在测试连接时尝试禁用它。最好将代理切换到在Linux上运行。

如果两个系统都能够通过DNS名称相互解析,则播发的侦听器只能是主机名。否则,节省额外的网络跳数,并使用IP作为通告的侦听器。如果您得到“无法解决”,则似乎是DNS问题,而ping windows-host也不应该起作用

kafkacat -b kafka-host:9092 -L
 类似资料:
  • 我有一个消费者作为生产者消费者模式的一部分: 简化: 如果我移除 通过将线程设置为睡眠,CPU使用率攀升到极高的水平(13%),而不是0%。 此外,如果我实例化该类的多个实例,则每个实例的CPU使用率都会以13%的增量攀升。 大约每分钟(可能每30秒)都会向BlockingCollection添加一个新的LogItem,并将适用的消息写入文件。 有没有可能线程以某种方式阻止了其他线程的运行,而系统

  • 我有一个循环缓冲区(数组/先进先出),一个消费者和一个生产者。生产者将随机数放入数组中,消费者获取第一个数字并检查它是否是相对素数。 我的代码工作正常,我认为它工作正常,但我想改进它。我不太确定我的“空运行”方法。我应该在其他地方做异常处理吗?改变“无限循环”?不应更改方法签名(它们是预定义的)。 我会很高兴每一个改进代码的建议。(不在乎知名度(公开,...),还有静态的东西,我刚刚把它们放在一个

  • 一、生产者发送消息的过程 首先介绍一下 Kafka 生产者发送消息的过程: Kafka 会将发送消息包装为 ProducerRecord 对象, ProducerRecord 对象包含了目标主题和要发送的内容,同时还可以指定键和分区。在发送 ProducerRecord 对象前,生产者会先把键和值对象序列化成字节数组,这样它们才能够在网络上传输。 接下来,数据被传给分区器。如果之前已经在 Prod

  • 问题内容: 我需要编写一个类似于生产者- 消费者的问题,必须使用信号量。我尝试了几种解决方案,但都无济于事。首先,我在Wikipedia上尝试了一个解决方案,但没有成功。我当前的代码是这样的: 使用者的方法运行: 生产者的方法运行: 在上面的代码中,发生了一个消费者线程读取一个位置,然后另一个线程读取了相同位置而没有生产者填充该位置的情况,如下所示: 问题答案: 似乎您使用的是互斥锁而不是信号灯?

  • 问题内容: 我对于如何使用特定的生产者-消费者模式感到困惑,在该模式中,生产者和消费者都可以同时并独立地进行操作。 首先,考虑以下示例,该示例紧随docs中的示例: 关于此脚本,有一个更详细的细节:通过常规的for循环将项目同步放入队列。 我的目标是创建一个使用(或)和的脚本。两者都应安排为同时运行。没有一个消费者协程明确地与生产者绑定或链接。 我如何修改上面的程序,以便生产者是可以与消费者/工人

  • kafka-python(1.0.0)在连接到代理时抛出错误。同时 /usr/bin/kafka-console-producer和 /usr/bin/kafka-console-consumer正常工作。 Python应用程序过去也运行良好,但是在动物园管理员重新启动后,它不再能够连接。 我使用文档中的裸露骨骼示例: 我收到这个错误: 单步通过( /usr/lib/python2.6/site-