回答情况：
提问时间：
问题标签：
3回答
我有关于kafka配置的问题。server1:卡夫卡生产者server2:卡夫卡经纪人，卡夫卡消费者，动物园管理员`./bin/kafka-co
浏览 1提问于2016-05-25得票数 6
2回答
Kafka附带了各种.sh script来在Kafka集群上执行管理活动，如主题创建、分区等。但我追求的是.sh script，它允许我检查(发现)构建块的活动(有效)配置，如代理、主题、分区等。是否有可用的.sh script在运行时执行此配置检查？ 注意:我想一起或理想地分开查看broker/topic/partition的所有配置键/值条目(包括默认值和覆盖项(如果有))。 提前谢谢。
浏览 25修改于2020-07-21得票数 0
2回答
我面临一个问题，卡夫卡集群设置，我有。我有一个卡夫卡集群，有两个经纪人连接到两个动物园管理员。node 2broker.id=0advertised.listeners=PLAINTEXT://
浏览 1修改于2020-02-17得票数 2
我必须构建像这样的日志集群和监视集群(为了高可用性)。我想知道如何配置那些日志发送者集群。(图中有2张Topo )
感谢您
浏览 5提问于2020-08-26得票数 0
我在这里请求一般的最佳实践：如果我想运行Kafka Connect distributed worker，是否要在所有群集节点上运行？使用Kafka流媒体应用，是否应该在所有集群节点上运行？它们应该停靠吗？它们
浏览 6提问于2017-06-01得票数 0
回答已采纳
我正在尝试使用Kafka connect仅向DB(消费者)提供一定数量的新行。我已经将它的源配置文件配置为 name=source-postgres当我启动connect-standalone.sh脚本时，我可以在控制台上看到batch.max.rows = 10。
浏览 0修改于2018-09-30得票数 3
我一直在跟踪Kafka Quickstart在一台机器上“设置一个多代理集群”。(只作测试用途)。listeners=PLAINTEXT://:9093broker.id=2现在，我想用三台机器创建一个集群
浏览 1提问于2019-10-31得票数 0
回答已采纳
我已经用集群中每个节点的URL配置了Apache中conf目录中的slaves.template文件。
我使用以下指令运行脚本：.master-url和master-port必须在spark-env.sh文件中配置相同。在脚本的火花配置上，我还添加了主url (val sparkConf = new SparkConf().setAppName("SparkScript").setMaster("spark://master-url
浏览 0修改于2017-07-30得票数 1
我在一个项目中使用kafka，具体来说，我使用的是合流云的托管kafka。我需要更新我的代理配置(特别是字段offsets.retention.minutes)，但我在的时候有点不知所措--应该怎么做。us-west1.gcp.confluent.cloud:44/v3:拨号tcp 35.247.31.53:44: i/o超时”(它似乎在做一些非常奇怪的事情，因为它降低了端口号.
confluent kafka我在网上看到了有关登录到代理和手动更改server.properties文件以包括我的
浏览 9提问于2022-11-30得票数 0
回答已采纳
我有以下设置：1个主题，12个分区和3个副本(因此每个kafka broker是4个分区的领导者)zookeeper tickTime = 2000
kafka
浏览 3提问于2016-02-03得票数 6
我有一个单一的spring引导应用程序，它需要使用来自两个不同的Kafka集群的主题的数据，这些主题具有独立的SSL信任(keystore和trusstore文件和位置)。是否可以在application.yml/properties文件中对其进行配置？使用卡夫卡/弹簧云流绑定/绑定？
任何线索/帮助理解如何通过yaml/属性文件如果是或如果不可能？我试图在spring.cloud.stream.bindings.consumer下配置第二个集群属性，在s
浏览 20修改于2022-11-26得票数 1
在我们的一个基于spring-boot的服务中，我们打算同时连接到两个不同的kafka集群。这些集群每个都有自己的一组引导服务器，主题配置等。我将在不同的主题名称上从每个集群读取不同类型的消息。可能有也可能没有多个生产者从这个服务连接到两个集群，但我们肯定每个集群至少有一个消费者。
浏览 25提问于2020-07-27得票数 1
回答已采纳
我知道与Mesos API的本地集成计划在Kafka 0.9版本中进行。同时，使用Marathon来运行和扩展Kafka brokers将是非常棒的。有没有人已经有过这样做的经验？
浏览 1修改于2014-11-13得票数 1
我想从一个kafka集群消费消息并发布到另一个kafka集群。想知道如何使用spring-kafka进行配置吗？
浏览 72提问于2021-01-08得票数 2
回答已采纳
我们正在使用kafka集群，我们希望监视这个集群。目前我们的做法是：
但是，我们面临着卡夫卡经纪人名单的静态配置问题我们只能通过Jmxtrans或Telegraf jolokia plugin配置静态列表。我们希望动态列表(例如，只配置kafka集群、动物园管理员连接，以便在每次收集度量的迭代中获得代理列表)用于<e
浏览 4修改于2017-04-13得票数 0
回答已采纳
当尝试在K8s集群中的“CMAK”中添加新群集时，将提示以下错误。zookeeper: wurstmeister/zookeeperkafka:wurstmeist
浏览 8提问于2021-05-11得票数 1
回答已采纳
我们在生产环境中有一个安全的Kafka集群(使用TLS加密、基于证书的客户端身份验证和ACL)。我正在尝试弄清楚如何使用适当的设置配置Flink Kafka连接器，以便它可以安全地连接到我们的Kafka集群。Flink可以做到这一点吗？我是否必须通过属性传递安全配置内容？我们的Flink集群运行在Kubernetes (1.14.2)上，并使用最新的Flink稳定版本(v1.8)和集成的kafka连接器。
浏览 39提问于2019-08-14得票数 1
我正在尝试使用默认的Kafka配置设置，但我不确定${akka.kafka.consumer}是如何设置的。阅读我定义了以下内容：our-kafka-consumer: ${akka.kafka.consumer} { }但是，当我启动Akka集群时，接收错误：
C
浏览 18修改于2022-02-28得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号