我制作了一个运行Kafka的Linux虚拟机。我测试了这个生成器，并且能够在我的另一台计算机上使用它。现在，我想创建一个在我正在处理的API中运行的使用者。 我正在尝试遵循一些教程，但它们令人困惑。我只想运行一个消费者，它将在我的项目中读取来自生产者的消息。我</em
浏览 5提问于2021-01-29得票数 0
我打算使用Spring boot和webSocket以及Kafka实现一个聊天室，但是我需要知道Kafka是否提供了异步消息传递服务
浏览 2提问于2019-07-02得票数 0
我正在使用kafka-net客户端向kafka发送消息。我只是想知道是否有任何方法可以检查kafka服务器是否启动并可以接收消息。我关闭了kafka，但是已经成功地创建了生产者，并且SendMessageAsync冻结了相当长的一段时间。我试图通过超时，但它不会改变任何事情。我使用kafka-
浏览 2提问于2016-03-05得票数 5
1回答
我们有一些用c#和go语言开发的微服务。我们使用confluent-kafka进行消息传递，并面临一个问题: Go服务能够使用所有其他服务(无论是来自go还是c#/.net微服务)发布的消息。但是，.net微服务不是从go微服务而是从.net微服务获得发布的消息。 我们在windows平台上，使用confluent-kafka作为<em
浏览 15提问于2019-04-19得票数 1
回答已采纳
我正在尝试设置一个Kafka集群(实际上是集群中的第一个节点)。当我启动kafka时，我得到了以下异常(导致kafka关闭)。编辑:我启动了kafka，我必须在se
浏览 1提问于2014-08-26得票数 18
回答已采纳
2回答
我在每个ubuntu的VirtualBox客户上都有两台服务器。我可以通过SSH从我的主机连接到这两台机器，并且在这两台机器之间使用natnetwork。我在一个服务器kafka上运行，如下所述： https://kafka.apache.org/quickstart 因此，我启动了单节点zookeper K
浏览 1031提问于2019-09-17得票数 7
回答已采纳
以下是我为kafka生产者编写的python代码，我不确定这些消息是否可以发布到Kafka代理。因为消费者端没有收到任何消息。当我使用生产者控制台命令对其进行测试时，我的Consumer python程序运行良好。from __future__ import print_function
from pyspark import SparkContext
from kafka
浏览 6提问于2016-09-13得票数 0
回答已采纳
我试图为第三方的Kafka和ZooKeeper服务器编写一个Java客户机。我能够列出和描述主题，但当我尝试阅读任何主题时，都会引发ClosedChannelException。我在这里用命令行客户端复制它们。-zookeeper 255.255.255.255:2181 --topic eventbustopic(将ips改为255.255.255.255)
当我搜索这个例外的时候，我看到了生产者方面的问题--事实<em
浏览 4提问于2015-06-02得票数 39
回答已采纳
System.out.println(e.toString()); consumer.close(); }我还引用了我的生产者代码Properties prop
浏览 3提问于2016-06-02得票数 8
回答已采纳
获得了一个现成的Kafka服务器，并有以下脚本use AnyEvent;
my $producer= Net::Kafka::Producer->new(
'bootstrap.servers' => 'localhost:
浏览 15提问于2022-03-20得票数 1
回答已采纳
1回答
我需要将消息接收到我的BigQuery表，我想知道使用这些消息的最佳方式是什么。我在AWS的Kafka服务器会生成AVRO消息，根据我所看到的，Dataflow需要接收JSON格式的消息。因此，我搜索并找到了一篇文章，解释了如何向PubSub接收消息，但在PubSub
浏览 1提问于2021-04-27得票数 3
回答已采纳
我的应用程序使用运行在一台机器上的Kafka服务器上的消息，然后将它们转发给另一个运行在其他实例上的远程Kafka。在我将我的应用程序部署到Cloud并向第一个Kafka服务器发送消息之后，应用程序将按预期工作。信息被消耗并转发给远程卡夫卡。但是，在此之后，我</em
浏览 2提问于2016-06-03得票数 0
回答已采纳
我想使用Kafka作为分布式应用程序服务器端的消息代理。我们的客户可以定位在世界各地，并向服务器发送频繁的消息。现在，这些消息只是ZMQ上的JSON。我正在考虑将客户机和服务器之间的连接更改为Kafka (因为我无论如何都要在服务器端<em
浏览 0提问于2018-12-14得票数 1
2回答
当我尝试同时向2个Kafka节点发送数据日志时，Filebeat出现问题output.kafka: hostsxxx.xx:9092", "192.168.zzz.zz:9092" ] timeout: 30s两个kafka我的
浏览 2提问于2018-11-17得票数 0
我有一台电脑，目前托管的是zookeeper和kafka服务器。我已经成功地构建并运行了一个运行消费者脚本的容器，但它将永远等待<em
浏览 17提问于2020-02-21得票数 0
回答已采纳
我正在尝试将大量iot对象连接到eventhub，并将它们保存到blob存储(也是sql数据库)。我想用python做到这一点(我不确定这是否是推荐的做法)。我尝试了几个示例，但它们创建了一个条目来存储blob，但是条目似乎无关紧要。这可不是我发的。我该如何解决这个问题呢？
浏览 1提问于2018-05-14得票数 1
我想找出将消息从Kafka路由到连接到负载均衡应用服务器集群的web套接字客户端的最佳方法。我理解spring为使用和发布到kafka主题的消息提供了便利，但是在负载平衡的应用服务器场景中，当连接到分布式kafka主题时，这是如何工作的。我可以看到如何在一个应用服务器
浏览 4提问于2019-10-15得票数 5
回答已采纳
我目前正在使用Google Cloud Dataflow和Apache Beam来消费来自两个不同Kafka集群中的Kafka主题的消息，这两个集群包含相同的主题名称，但主题中的数据不同。Kafka集群是分开的，因为它们包含来自不同区域的数据。
我只是想知道，是否可以通过在单个KafkaIO.read数据流管道步骤中列出两个群集的所有引导
浏览 23提问于2020-05-13得票数 0
我正在使用JMeter中的pepprBox示例连接kafka服务器并发送主题消息。应用程序团队共享两个JKS证书以及连接Kafka服务器的密码。为此，我在system.properties文件中启用了密钥库属性：javax.net.ssl.keystore= javax.net.ssl.keystorepassword= 和jmeter.properties中的索
浏览 38提问于2020-04-26得票数 0
回答已采纳
2回答
我在docker中运行Kafka，我有一个.NET应用程序，我想使用它来使用消息。我在没有运气的情况下遵循了下面的教程：
172.21.0.3:9092/bootstrap: Connect to ipv4#172.21.0.3:9092 failed: U
浏览 18提问于2021-05-10得票数 1
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
