我在通过kafka库连接Event Hub时出现以下异常。:687) ~[kafka-clients-2.2.1.jar!:501) ~[kafka-clients-2.2.1.jar!:435) ~[kafka-clients-2.2.1.jar!~[kafka-clients-2.2.1.jar!
浏览 57提问于2020-01-24得票数 4
1回答
我们使用Microsoft事件中心端点作为Kafka集群。应该使用哪个版本的Kafka客户(生产者和消费者)与事件中心进行交互？
浏览 2提问于2022-04-21得票数 0
回答已采纳
我在docker网络中运行Apache Kafka。Kafka代理的容器称为docker_kafka。我想要的是允许从Kafka客户端从另一个码头容器以及从码头主机连接。docker_kafka的端口9092已映射到坞站主机。
我一直在尝试KAFKA_LISTENERS和KAFKA_ADVERTISED_LISTENERS环境变量。例如，当我使用KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0
浏览 1提问于2017-03-29得票数 4
我已经为kafka构建了一个docker镜像(wurstmeister/kafka-docker)。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用托管在上的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么也不会发生，程序就会卡住。我猜producer.send无法连接到kafka broker。
浏览 2提问于2017-02-03得票数 1
2回答
dockerize应用程序后，docker日志将显示在卡夫卡日志中，它显示了 ports: environment: kafka:
image: 'bitnami/kaf
浏览 16提问于2021-12-07得票数 3
我想连接到卡夫卡使用端口80在我的Azure虚拟机。我在虚拟机上安装了Java和Kafka。我为端口80添加了入站端口规则。
但是我不
浏览 4提问于2020-09-04得票数 0
回答已采纳
我正在尝试使用Docker运行Kafka和Zookepper，遵循这里定义的步骤：docker run -p 2181:2181 -p 9092:9092env ADVERTISED_HOST=`docker-machine ip \`docker-machine active\`` --env ADVERTISED_PORT=9092 spotify/kafka
浏览 7提问于2018-01-07得票数 1
回答已采纳
我使用一个带有后端api(app服务)连接的APIM资源。下面是我通过APIM从app服务中读取来自eventhub的数据所做的全部设置。
现在我已经知道了这方面的“日志到事件”策略，但我的公司并没有使用这种策略。他们要求我按照
浏览 1提问于2022-06-30得票数 0
1回答
{ "apiVersion": "2018-01-01-previewb43e2eab4d9b')]", "dependsOn": [
"[resourc
浏览 19提问于2019-07-17得票数 0
回答已采纳
我需要通过Spring Boot启用kafka连接到event hub，并且我有连接字符串和名称空间，我应该在哪里连接。我应该如何连接到EventHub？
浏览 51提问于2020-08-03得票数 4
回答已采纳
CONFIG_STORAGE_TOPIC: my_connect_configskafka-connect_1 | 2020-10-18 04
浏览 139提问于2020-10-18得票数 1
未能创建主题2021-04-27T08:48:12.806690772Z org.apache.kafka.common.errors.PolicyViolationException:服务无法处理请求在使用Spring引导、事件中心和Kafka时，我正面临上述问题。下面是我所关注的依赖关系。<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</ar
浏览 5提问于2021-04-27得票数 0
因为每个实例都需要一些特定的配置，所以我正在为每个实例创建一个RC和一个服务--急切地等待 ;)
但是，我遇到了问题，因为Kafka在使用服务IP时无法建立到它自己的网络连接( Kafka broker由于某些原因，无法建立连接，也无法发送消息。更多信息:如果我手动连接到kafka1吊舱，我可以使用它们各自的集群IP (11.1.2.120 / 11.1.2.123)正确地将kafka2和kafka3连<e
浏览 8提问于2016-01-22得票数 10
我有一个web应用程序运行在docker容器中，一个kafka broker运行在另一个docker容器中。我正在使用码头-合成来设置码头集装箱。但是我发现要为码头容器配置网络有点困难。现在，我的web应用程序可以向kafka码头容器生成消息。但我还有另一个问题:我可以通过ifconfig docker0获得docker主机ip，并将其硬编码到dockerCompose.yml中。因此，我们需要一些可靠的方法来通过一些程序自动和动态地获取ip。。
有什么想法吗？谢谢
浏览 1提问于2018-01-26得票数 2
这将阻止Mongo Compass通过连接字符串直接连接到cosmosdb。有没有任何方法将其连接到Gateway？或者还有其他桌面用户界面将与Azure网关一起工作？
浏览 9提问于2022-07-18得票数 0
我在WSL上运行Kafka。A0</code><code>A1</code><code>A2</code>
我的问题是，在WSL上运行kafka
浏览 71提问于2020-06-08得票数 3
回答已采纳
1回答
我决定使用Kafka来进行聊天、消息订阅和发布，因为我不能使用STOMP (我选择的是Servlet而不是Servlet)。
根据我的计划，聊天消息的交换是通过以下过程进行的。client A通过WebSocket.client B连接到chat server 1，通过WebSocket.chat server1 and 2连接到chat server 2，订阅Kafka topic'chat'client A将聊天消息发送到
浏览 5提问于2020-10-07得票数 1
2回答
version: '3.2' zookeeper: ports: kafka: ports: - "29092:29092" KAF
浏览 1提问于2020-02-18得票数 1
1回答
我创建了3个代理节点和3个带有docker-compose.yml的动物园节点，当我创建主题或生成和添加消息时，会显示“g.apache.kafka.clients.NetworkClient)”警告AdminClientclientId=adminclient-1连接到节点-2 (localhost/127.0.0.1:29092)。“
似乎领导者、经纪人和跟随者无法相互联系。我怎么才能解决这个问题？
浏览 3提问于2021-09-23得票数 0
2回答
代码非常基础，试图通过空格连接主题分词，并将其打印到控制台。Kafka版本是0.9。import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.fl
浏览 36提问于2019-08-20得票数 3
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
