我试图使用更流行的kafka-node库连接到EvenHub的Kafka，但不幸的是，我无法让它工作。如果我使用node-rdkafka包，一切都可以正常工作，但这看起来不再需要维护太多。(我正在使用带有连接字符串的SASL_SSL ) 你知道有什么有效的例子吗?或者它是否在任何情况下都有效？ 非常感谢！
浏览 23提问于2019-07-04得票数 0
回答已采纳
1回答
我正在使用kafka节点模块向kafka发送消息。在集群环境中，我有一个主题，其中有3个分区，复制因子为3。当我遵循下面的步骤
kafka:9093send 获取连接到kafka:9092的HighLevelProducer实例，a message 停止kafka-server:9092手动，然后用HighLevelProducer我期望的是，如果一个分区无法访问(代理已经关闭)，生产者应该自动将数据发送到下一个可用
浏览 3提问于2019-09-23得票数 1
我尝试通过kafka-node npm库使用consumer和producer，以便通过nodejs使用kafka作为消息服务。问题是，尽管我的生产者有时会工作，但消费者总是给我超时错误，或者它只是在无休止的循环中尝试连接到kafka，即使tought也工作得很好。当Kafka在远程centos7机器上时，我在windows机器上使用kafka-node。当我测试kafka和zoo
浏览 56提问于2019-06-19得票数 3
我已经编写了一个节点模块来连接Kafka。kafka-connect.js client = new]; } KafkaService现在我正在使用这两个工具
浏览 3提问于2018-12-05得票数 0
我已经开发了一个基于Java的Kafka消费者，其中每个消费者实例都有100个线程，当消费进程开始时，每个线程都会得到一个分区(因为有100个分区)，消费就完成了。我计划切换到nodejs，并使用kafka-node作为客户端库，我正在消费该主题，如下所述：var HighLevelConsumer= kafka.HighLevelConsumer;
var Client = <
浏览 5提问于2015-08-22得票数 1
我想在启用了Kafka的Azure中自动部署事件中心。
我可以使用"Microsoft.EventHub/namespaces“资源上的ARM模板属性来启用Kafka吗？如果没有，有没有办法在使用PowerShell的事件中心上启用Kafka？
浏览 5提问于2018-07-26得票数 0
回答已采纳
我们正在使用运行在Azure Container实例中的Kafka MirrorMaker 1将记录从kafka集群发送到Microsoft Azure Eventhub。我们的主题有10个分区，我们在Azure EventHub中手动创建了一个具有相同名称和分区数量的主题。不幸的是，记录在被MirrorMaker 1复制后失去了原始分区。有没有办法使用MirrorMaker 1保
浏览 46提问于2021-08-24得票数 0
我正在使用Apache Flink，并尝试使用Apache Kafka协议连接到Azure eventhub以接收来自它的消息。我设法连接到Azure eventhub并接收消息，但我不能使用flink功能"setStartFromTimestamp(...)“如下所述()。当我试图从timestamp获取一些消息时，Kafka说broker端的消息格式是0.10.0之前的</em
浏览 8提问于2019-03-21得票数 0
我需要通过Spring Boot启用kafka连接到event hub，并且我有连接字符串和名称空间，我应该在哪里连接。我正在使用这样的依赖关系我找到了一个教程，其中我需要从本地机器使用az login登录到azure并创建auth文件，但是我得到了应该使用的连接字符串，所以有没有办法只使用如下命名空间的连接字符串我应该如何连<em
浏览 51提问于2020-08-03得票数 4
回答已采纳
我创建了一个生产者和一个消费者，使用“Kafka节点”包发送和消费来自kafka主题的信息。生产者和消费者通过API调用。POST方法用于向主题发送消息，而GET方法用于在使用者处从主题获取消息。当我在向KAFKA发送消息之后调用消费API时，所有以前的消息都在consumer.on('message', function(message){})中得到了安慰。producer.js
var kafka = require('
浏览 6提问于2021-12-15得票数 0
我在docker网络中运行Apache Kafka。Kafka代理的容器称为docker_kafka。我想要的是允许从Kafka客户端从另一个码头容器以及从码头主机连接。docker_kafka的端口9092已映射到坞站主机。
我一直在尝试KAFKA_LISTENERS和KAFKA_ADVERTISED_LISTENERS环境变量。例如，当我使用KAFKA_ADVERTISED_L
浏览 1提问于2017-03-29得票数 4
1回答
我正在使用kafka接收来自数据源的数据，我正在开发用Node.js编写的消费者应用程序，并使用kafka-node连接到kafka服务器。另一方面，生产者是用Java编写的，他们使用一些kafka流媒体库来产生带有模式的avro消息。34:19.003Z\u0000\u0002\u000e3010985\u0002T83dc24eb6aac\u0002.2021-06-21T09
浏览 42提问于2021-06-23得票数 0
我正在寻找是否有任何方法可以将schema-registry与Kafka-node模块一起使用。我已经探索过了，但没有成功地找到任何东西。在这方面的任何帮助都将不胜感激。
浏览 0提问于2017-10-25得票数 8
1回答
我有一个卡夫卡用户的node.js应用程序。订阅处理程序使用"fetch“来调用远程REST API (await fetch(...))。我尝试处理高频率的消息，REST调用由于远程服务器的过载而失败。我的问题是:有没有办法确保异步处理程序是序列化的，这样就不会同时调用远程API服务器？克里斯:我用的是kafka-node
下
浏览 1提问于2018-08-13得票数 4
有没有办法在不使用HDInsight的情况下从公共网络连接到Azure VPN Kafka集群？是否只能从Azure网络中的连接到Azure Kafka群集？ 谢谢
浏览 33提问于2020-08-16得票数 0
我已经创建了一个jar，其中包含用于SASL回调的类文件，并且存在于我的应用程序目录中。有没有办法将这个jar链接到Kafka启动(使用kafka-server-start.sh脚本)，而不必在Kafka的libs目录下显式复制这个jar？
环境: RHEL
浏览 2提问于2021-09-15得票数 2
我的Spring boot项目有4个模块，我需要使用Kafka在模块之间建立通信。我在我的电脑上安装了Kafka，并使用cmd创建了主题。问题是，在我提交我的项目后，除非我的老师在他的计算机上创建了相同的主题(根据我所理解的)，否则主题将不起作用。 有没有办法确保我的项目自动创建主题？
浏览 244提问于2021-10-14得票数 0
回答已采纳
我正在开发一个使用kafka streams API的服务。下面是一些背景知识。我正在尝试为我的服务增加弹性。也就是说，如果我的服务没有连接到kafka，那么它应该发出警报，通知我们有问题。我正在使用KafkaStreams.setStateListener()安装一个侦听器，该侦听器会在kafka
浏览 1提问于2019-03-07得票数 1
我在Android 3.2中使用SPP蓝牙时遇到了问题。我做了一个连接蓝牙设备的程序(也尝试了Android Market上的一些免费应用程序)。我有几个使用蓝牙2.1和2.0的设备。该程序可以通过蓝牙2.0连接到设备，但不能连接到2.1。我认为这是由蓝牙2.1中更安全的协议引起的。有没有办法强制程序使用蓝牙2.0连接到2.1设
浏览 6提问于2011-12-13得票数 1
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
