使用Kafka工具，我的配置如下： Zookeeper Host:192.168.60.97chroot path: /kafka1 但是当我尝试这个的时候consumer, err = sarama.NewConsumer([]string{"192.168.60.97:2181:/kafka1"}, nil) 我总是得到 kafka: client has
浏览 29提问于2020-04-02得票数 0
回答已采纳
5回答
bin/kafka-topics.sh --create --topic activityTopic --zookeeper localhost:2181/kafka --partitions 1 --replication-factor 1at kafka.utils.ZkUtils$.getSortedBrokerList(ZkUtils.scala:78)
at k
浏览 23提问于2016-02-01得票数 11
回答已采纳
1回答
是否有可能设置卡夫卡使用子上下文？因此，其他服务最终不能修改其他服务的子上下文。它将是： /service1/... /kafka/consumers/...
让我们说。所以，卡夫卡只会看到brokers和c
浏览 0提问于2016-02-24得票数 7
回答已采纳
1回答
我正在使用Influxdb 2.0版，并希望将kafka consumer leagcy插件与它连接起来。我想知道我应该如何配置这个kafka消费者遗留的配置文件，以及将其放置在服务器/本地机器上的路径？kafka消费者legaccy的配置文件如下： # Read metrics from Kafka topic(s) ## topic(s) toconsume
topics = [
浏览 24提问于2021-07-29得票数 0
/bin/zookeeper-server-start.sh config/zookeeper.properties在kafka中运行了zookeeper，并通过跟随./bin/kafka-server-start.sh config/server.properties运行了kafka服务器。 我尝试将kafka服务器连接到德鲁伊服务器以输入数据。当我尝试运行druid的zookeep
浏览 85提问于2021-07-22得票数 0
: KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP1 --partitions 1 并使用Golang生产者以编程方式创建消息，同时使用控制台客户端监听它们： docker exec broker kafka-console-consumer
浏览 315提问于2021-05-09得票数 0
我尝试停止，修改server.properties文件，将分区数增加到3，然后重启Kafka。然而，这似乎并没有改变任何事情。使用Kafka ConsumerOffsetChecker，我仍然看到它只使用了2个分区。我使用的版本是0.8.2.2。在0.8.1版本中，曾经有一个名为kafka-add-partitions.sh的脚本，我猜它可能会做到这一点。然而，我在0.8.2中没有看到任何这样的脚本。
有什么办法做到这一点吗？
浏览 72提问于2015-11-13得票数 98
回答已采纳
1回答
当我将kafka-0端口公开为9093并按以下方式设置KAFKA_ADVERTISED_LISTENERS时，我无法连接到localhost:9093，如下面的docker-组合文件所示。- KAFKA_ZOOKEEPER_CONNECT=wise-nlp-zookeeper:2181
- KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT://localhos
浏览 3提问于2020-04-16得票数 4
回答已采纳
但我在尝试生成消息时出现错误 错误：poll | {"level":"ERROR","timestamp":"2020-10-24T15:21:27.113Z","logger":"kafkajs",": wurstmeister/zookeeper:latest - "2181:2181" - blueorigin
<em
浏览 61提问于2020-10-25得票数 2
回答已采纳
1回答
我有一个应用程序，建立风暴连接卡夫卡主题。我从我们的组织中的另一个类似的回购中模仿的设置具有如下属性：我发现在这个设置下，在我的本地开发环境中，我的应用程序在尝试创建风暴喷口时会抛出一个错误(DynamicBrokersReader.java:91) ~[storm-kafka-0.9.6.jar:na]
当我从属性中取出尾随的/kafka_0.9时</e
浏览 0提问于2018-01-17得票数 0
回答已采纳
1回答
- KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper-server:2181 - ALLOW_PLAINTEXT_LISTENER=yes - zookeeper-server
安装时没有任何问题3888/tcp, 0.0.0.0:2181-&
浏览 6提问于2020-02-10得票数 0
回答已采纳
使用jar生成的connectorFYI：<code>H 110</code>设置安装AWS cli并配置它，并配置它安装maven编译连接器设置类路径，设置我有一个停靠器的属性文件-组合，创建所有容器(以上所有这些都是在前提下设置的) - "9093:9093&q
浏览 12提问于2022-09-28得票数 0
我正在尝试通过命令行按照Apache Kafka网站上的指南创建Kafka主题。运行该命令时：06056566d0004 (org.apache.zookeeper</em
浏览 2提问于2015-10-13得票数 58
2回答
我正在尝试构建一个以Kafka为界面的Flask应用程序。我使用了Python连接器、和Docker图像作为Kafka，。ADVERTISED_PORT=9092 - TOPICS=PROFILE_CREATED,IMG_RATED depends_on:下面是我用来
浏览 1提问于2018-11-27得票数 5
我正在尝试在我的主机maschine上安装Kafka / Docker，并从网络设备连接到它。我用的是比特尼/卡夫卡。: environment:from kafka</e
浏览 1提问于2020-04-19得票数 0
回答已采纳
3回答
因此，这应该是在内外设置正确的广告商的问题：services: image: wurstmeister/zookeeper KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INSIDE:PLAINTEXT: INSIDE:&#x
浏览 2提问于2018-11-11得票数 27
回答已采纳
我想在同一个L2网络上创建4个Kafka集群(每个集群有3个节点)。
这样做有可能吗?怎么做？如果没有，那有什么解决办法呢？
浏览 3提问于2016-09-07得票数 0
回答已采纳
4回答
我从阿帕奇卡夫卡开始，当我试图从外部机器上接触时，我正面临着问题。 image: wurstmeister/zookeeper:3.4.6 - 2181:2181 image: wurstmeister: 9092
KAFKA_ZOOKEEPER
浏览 3提问于2017-07-28得票数 2
回答已采纳
我已经创建了Kafka Standalone.properties文件来建立一个连接。zk# You can also append an optional chroot该文件放置在路径home/kafka-connect-cassandra-接收器-1.4.0中，文件如下：connector.class=com.d
浏览 3提问于2021-08-09得票数 0
回答已采纳
我找到了这张卡夫卡的码头图片我可以使用链接中记录的命令轻松地创建一个docker容器这很好但是我想配置一个运行在docker集群上的“多”节点Kafka集群。
浏览 2提问于2016-05-25得票数 11
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
