生产者/消费者的java代码无法在docker设置中连接kafka
我为Kafka建立了一个docker形象（Wurstmeister/Kafka-Docker）。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用https://github.com/mapr-demos/kafka-sample-programs托管的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么都没有发生，程序就会堆积起来。我猜Producer.Send无法连接到kafka Broker。感谢任何帮助
共有1个答案
您可以看到该项目中的consumer.properties和producer.properties文件都指定了bootstrap.servers=localhost:9092。
由于您无法使用localhost:9092连接到dockerized kafka服务，因此您可以尝试使用docker inspect kafka grep ipa（假设您的容器的名称是kafka)查找docker容器的IP地址。然后将localhost替换为这两个属性文件中的IP地址。
-
尝试学习线程的多线程和进程间通信。实施了一个典型的生产者-消费者问题。然而，am获得的输出是相当连续的，这在理想情况下不应该是使用线程的情况。 好的，下面是完整的代码： 生产者线程： 使用者线程： 现在，当我运行程序时，生产者线程总是比消费者线程先运行。即使我创建了多个生产者/消费者，结果也是一样的。以下是单个生产者和单个消费者的产量： 有人能解释一下这里的行为吗？我已经在这里读了很多答案，但我想
-
本教程演示了如何发送和接收来自Spring Kafka的消息。 首先创建一个能够发送消息给Kafka主题的Spring Kafka Producer。 接下来，我们创建一个Spring Kafka Consumer，它可以收听发送给Kafka主题的消息。使用适当的键/值序列化器和解串器来配置它们。 最后用一个简单的Spring Boot应用程序演示应用程序。 下载并安装Apache Kafka 要
-
生产者线程与消费者线程使用信号量同步 生产者线程与消费者线程使用信号量同步 源码/* * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: * Date Author Notes * 2018-08-24 yangjie the f
-
所谓的生产者消费者模型就是 某个模块（函数）负责生产数据，这些数据由另一个模块来负责处理 一般生产者消费者模型包含三个部分 生产者、缓冲区、消费者 为什么生产者消费者模型要含三个部分？直接生产和消费不行么？ 一个案例说明一切 生产者好比现实生活中的某个人 缓冲区好比现实生活中的邮箱 消费者好比现实生活中的邮递员 如果只有生产者和消费者, 那么相当于只有写信的人和邮递员，那么如果将来过去的邮递员离职
-
现在我正面临着连接生产者/消费者的问题。 > 我使用以下命令创建了一个客户端密钥存储库, 将CA证书添加到密钥库, 警告与节点-1的连接在身份验证期间终止。这可能表明身份验证由于凭据无效而失败。（org.apache.kafka.clients.NetworkClient） 怀疑我在客户端配置中缺少了什么。如有任何帮助，将不胜感激。
-
我有一个消费者作为生产者消费者模式的一部分： 简化： 如果我移除 通过将线程设置为睡眠，CPU使用率攀升到极高的水平（13%），而不是0%。 此外，如果我实例化该类的多个实例，则每个实例的CPU使用率都会以13%的增量攀升。 大约每分钟（可能每30秒）都会向BlockingCollection添加一个新的LogItem，并将适用的消息写入文件。 有没有可能线程以某种方式阻止了其他线程的运行，而系统