1回答
查询:将路由器接口作为kafka集群的生产者。问题2. kafka消费者可以在不指定主题的情况下拉取数据吗？我刚刚检查了Kafka broker配置是否有"auto.create.topics.e
浏览 1提问于2014-06-18得票数 0
我使用的是Dockerized static Kafka集群(0.11)，它有3个代理。这个集群的问题是，如果所有代理都在同一端口上运行，则控制器节点不允许我创建主题。以下是我的代理配置模板：broker.id.generation.enable=falsedelete.topic.enable={{KAFKA</
浏览 14提问于2018-02-19得票数 0
当生产者首次向主题发布消息时，AWS MSK群集不会自动创建主题。这是令人惊讶的，因为根据的默认行为应该有auto.create.topics.enable = true。我试图在代理上设置此配置，但我无法设置，因为配置是用于动态更新的read-only。$ kafka-configs --bootstrap-server $KAFKA_BROKER --entity-type brokers --entity-default --alter --add-configa
浏览 0提问于2019-04-26得票数 9
回答已采纳
我有一个包含3个节点的kafka集群。当Node #3死掉时，我的_schemas主题停止正常工作，我看到以下内容：kafka.common.NotAssignedReplicaException:
浏览 2提问于2018-02-08得票数 12
我使用sql-server kafka-connect和debezium来监视sql server数据库，但是当我发布并运行我的工作程序时，主题已经用名称{server_name}.{table_name}和默认的partitions=1 & replication=1创建了，即使我在"bootstrap.servers“参数中指定了两个代理。如何手动更改表主题的分区和复制，或者在worker/connector配置中预先指定？此外，不同的主题可能有不同的分区和复制。
浏览 0提问于2019-12-30得票数 2
1回答
KAFKA_ADVERTISED_LISTENERS=INSIDE://kafka-broker:9093,OUTSIDE://localhost:9092KAFKA_LISTENERS=INSIDE://kafka-broker:9093,OUTSIDE:/
浏览 0提问于2020-12-07得票数 0
回答已采纳
我已经为kafka构建了一个docker镜像(wurstmeister/kafka-docker)。在docker容器中，我可以使用内置的shell脚本创建主题、生成消息和使用消息。现在，我使用托管在上的代码从我的主机连接到kafka broker。在构建和运行程序之后，什么也不会发生，程序就会卡住。我猜producer.send无法连接到kafka broker。
浏览 2提问于2017-02-03得票数 1
现在，我无法访问我的ruby客户端的任何主题，因为节点“不存在”。我指定"KAFKA_AUTO_CREATE_TOPICS_ENABLE：'false'“是因为我想手工创建主题，所以我输入了第一个代理容器并输入了以下内容：
./kaf
浏览 3提问于2018-11-05得票数 2
回答已采纳
我能得到一个例子，用赛段多的卡夫卡-围棋创建一个主题吗？我试着创建了一个主题如下：kt := kafka.TopicConfig{Topic: "sometopic", NumPartitions如果主机:端口不是卡夫卡领袖，那么我将得到以下错误：
通过集群地址创建主
浏览 3提问于2020-05-05得票数 2
4回答
主题通常驻留在broker (服务器进程)中，并且具有多个分区，但它能跨越多个代理或节点(计算机)吗？
也就是说，假设一个主题被分为两个分区，分区-1和分区-2。分区-1是否属于代理-1和分区-2的相同主题属于不同的代理-2或完全不同的节点？
浏览 0提问于2016-07-07得票数 13
回答已采纳
4回答
我的集群默认开启kafka机架感知吗？如果我用broker.rack配置一些brokers，让其他没有broker.rack的brokers，kafka机架感知会影响我的集群吗？
浏览 1提问于2020-01-05得票数 2
我正在测试一个用以下命令创建的容器化kafka实例：-e KAFKA_BROKER_ID=1-e KAFKA_INTER_BROKER_LISTENER_NAME=BROK
浏览 23提问于2022-11-15得票数 0
我尝试通过kafka-node npm库使用consumer和producer，以便通过nodejs使用kafka作为消息服务。当Kafka在远程centos7机器上时，我在windows机器上使用kafka-node。我试着在kafka内置的生产者控制台中发送消息，但我的消费者似乎仍然不能成功订阅主题并获得消息。":{"0":15743}}
sent 100 transactions to kafka 这是我的简单消费者： kaf
浏览 56提问于2019-06-19得票数 3
我正在尝试设置星火流从Kafka队列中获取消息。Either.scala:97)from pyspark.streaming import StreamingContext
directKafkaStream = KafkaUtils.createDirectStream(ssc, ["test-topic"], {"metadata.broker.list在我的“测试主题
浏览 10提问于2015-12-15得票数 14
3回答
我需要在一个卡夫卡主题存储的消息数量。这与是否有消费者消费了消息无关。kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092,localhost:9093,localhost:9094--topic test-topic
上面给出了主题的偏移量？以上数据是否等于kafka topic当前存储的消息数？
浏览 0提问于2018-08-23得票数 0
1回答
当我使用生产者时，消息会保存在主题中(我已经检查过了)，但是当我试图使用使用者获取消息时，它是不工作的，我也不知道为什么。 image: 'confluentinc/cp-kafka:latest' depends_on: - 9092:9092 KAFKA_BROKER<
浏览 13提问于2022-02-28得票数 0
回答已采纳
Zookeeper version: 3.4.10每台Kafka代理机器包括以下服务Zookeeper server代理机器- kafka01, kafka02 , kafka03 , kafka04 , kakfa05 , kafka05
安装在3 zookeeper上的kafka01, kafka02 , kafk
浏览 2提问于2020-08-19得票数 1
回答已采纳
如何获得当前偏移量、分区偏移量或给定主题的记录计数？它不需要是完美的，但我想要一个大概的想法，多少数据是卡夫卡的主题。
浏览 0提问于2018-07-03得票数 1
回答已采纳
1回答
我正在尝试设置一个代理服务器(java中的首选服务器)，它可以将我的连接流传递给kafka broker。Client (Consumer/Producer) <--> [PROXY SERVER] <--> Kafka Broker
我的用例是使用kafka提供的数据，但是配置参数应该代理给kafka broker例如bootstrap.servers=xx.xx.xx.xx:9091, topic=<encrypted-top
浏览 1提问于2019-05-22得票数 3
这绝对不是做这件事的方法，它可能应该由清理策略来处理，但这不是重点。假设log.dirs中的文件已被删除，会有什么影响？ 经纪人会崩溃吗？ 重新启动服务后，偏移量会从0重新开始吗？ 是否有必要采取任何措施进行修复？
浏览 64提问于2019-05-21得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
