我尝试将所有客户端的默认配额设置为0，以便在覆盖配额配置之前，它们最初不应发送/使用任何消息。./bin/kafka-configs.sh --alter --add-config 'producer_byte_rate=0,consumer_byte_rate=0'
浏览 12提问于2018-03-02得票数 0
我在它的评论中找到了这一行：“代理的配额回调接口，它支持客户配额计算的定制”--.but--它没有任何子类，为什么?我搜索了它，但找不到一个例子。
浏览 0提问于2018-08-28得票数 1
回答已采纳
1回答
我如何确保Pub/Sub模式中的公平性，例如kafka，当一个出版商生成数千条消息，而所有其他生产者的信息数字都很低的时候？谁的生产活动会很高，这是不可预测的。在这种情况下，多个分区也不能很好地工作，或者我可以看到它是如何工作的。
浏览 3提问于2021-06-10得票数 0
回答已采纳
1回答
我对卡夫卡非常陌生，我想了解卡夫卡的配额制是如何运作的。到目前为止，我一直在跟踪文档
我还使用以下命令来度量Kafka主题的吞吐量
浏览 2提问于2017-03-13得票数 2
我在使用Terraform的AWS上部署Bitanmi Kafka Helm图表。我发现文档存储和持久性分配非常令人费解。据我从文档中了解到的；日志是主题中的消息块，当超过可配置的字节、消息或时间配额时，日志会被刷新到存储中的文件中。我能否配置一个故障安全，即配置Kafka以保留所有内容，并在超出配额的情况下删除旧日志文件？如何检索持久化日志？使用者是否可以要求早期偏移量中的主题消息，并导致延迟或失
浏览 0提问于2021-05-30得票数 0
1回答
我是Apache Kafka的新手，我希望创建一个小的微服务/程序(可能是用Java编写的)来使用来自Kafka的消息并解析它们来构建XML文件。我已经有消息出现在我的单个Kafka主题中(发布者是第三方应用程序)，但我需要实时解析它们(所以我认为某种bash脚本可能是不可能的)。
我也有很少的Java知识，但目前正在努力学习基础知识。最终，我们将构建XML文件，然后使用curl发出POST请求，将文件发送到HTTPS网关。我的工作和现有的知识只是围绕着将消息
浏览 0提问于2021-09-27得票数 0
1回答
当Spark作业在没有Docker的情况下通过spark-submit在本地运行时，一切工作正常。但是，在停靠容器上运行会导致不生成任何输出。为了查看Kafka本身是否正常工作，我将Kafka提取到Spark worker容器上，并让控制台使用者监听相同的主机、端口和主题(kafka:9092，crypto_topic)，它们工作正常并显示输出:
image: wurstmeister/kafka</
浏览 21提问于2020-09-11得票数 0
我想为每个生产者和消费者设定配额。例如，使用以下命令设置配额： --alter --add-config 'producer_byte_rate=1048,consumer_byte_rate=2097'我的问题是:如何获取实体名称？因为现在有成百上千的生产者
浏览 35提问于2018-06-24得票数 0
回答已采纳
我试图在代理上设置此配置，但我无法设置，因为配置是用于动态更新的read-only。$ kafka-configs --bootstrap-server $KAFKA_BROKER --entity-type brokers --entity-default --alter --add-config--entity-type brokers --entity-default --alter --add-config auto.create.topics
浏览 0提问于2019-04-26得票数 9
回答已采纳
我使用KafkaPublish处理器将消息发布到使用SASL_SSL安全协议保护的kafka主题(我们不使用Kerberos)。(KafkaChannel.java:61) at org.apache.kafka.common.network
浏览 0提问于2018-09-11得票数 1
回答已采纳
我正在尝试使用xml配置在遗留web应用程序上设置kafka使用者，该应用程序运行的是Spring5.2发布项目(它不是Spring引导项目)。在查找之后，我发现了一个使用xml配置设置kafka消费者的项目，如下所示 https://docs.spring.io/spring-kafka/docs/1.3.11.
浏览 26提问于2020-11-08得票数 1
回答已采纳
我想在库伯奈特斯配置卡夫卡经纪人。我使用的对接图像是confluentinc/cp-kafka:latest。如果我使用的是来自kubectl get endpoints -l app=kafka的服务端点IP，这是可行的，但是每次使用一些审计脚本设置这个动态值是很小的开销。我想知道是否有更好的方法可以在Kubernetes yaml文件中动态设置这个值，所以我不需要每次都以编程方式<em
浏览 1提问于2018-04-29得票数 3
我们正在使用kafka 0.10.x，我正在寻找，如果有办法阻止发行商kafka停止发送消息后，某些消息/限制是在一个小时内达到。这里的目标是限制用户只发送特定数量的消息和小时/天？
浏览 2提问于2017-08-06得票数 3
我正在使用kafka_2.9.2-0.8.1.1和zookeeper 3.4.6。bin/kafka-topics.sh --zookeeper zookeeper01.mysite.com --config
浏览 0提问于2015-03-26得票数 1
回答已采纳
我一直在试验Kafka，并从主站点的文档中看到，您可以为jvm设置不同的选项，比如堆大小和它使用的垃圾收集器：
然而，它没有说的是如何/在哪里设置这些选项。该应用程序附带了一个/config目录，其中包含了许多用于配置目的的文件，但没有一个是用于Java的。它还附带了一个/bin目录，其中包含一堆用于Kafka的脚本，但是，没有真正指明如何配置Java</em
浏览 13提问于2014-12-28得票数 51
回答已采纳
我如何在Kafka REST代理中建立一个生产者和消费者？如果我使用kafka-clients.jar并在java中实现它，我可以轻松地进行所有设置。acks，提交方法，等等。我知道，基础可以设置在汇合-4.1.1/ etc / kafka-rest。参考资料：
浏览 2提问于2018-07-02得票数 0
2回答
我想在我们的微服务中实现发件箱模式，使用Mongo连接器，在发件箱( MongoDB集合)中，我使用以下字段存储主题数据：kafka_topic、kafka_key、kafka_value、kafka_header_keys、kafka_header_values。但是，我应该如何配置mongo连接器来动态地从kafka_topic字段中选择主题，以及如何从其他发
浏览 3提问于2020-12-25得票数 2
2回答
有超过50个Java应用程序(它们不是微服务，所以我们不必担心服务的多个实例)。现在，我的架构师设计了一个解决方案，获取日志文件并提供给kafka主题，然后从kafka提供给logstash并推送到elastic search，这样我们就可以在kibana中查看日志。现在我对Kafka和ELK stack是个新手。谁能给我指出如何完成这项任务的正确方向？我了解到可以配置Log4J和SLF4J将日志推送到kafka主题。1.现在如何从<
浏览 5提问于2019-07-18得票数 1
1回答
dependency> <artifactId>spring-integration-java-dsl<scope>test</scope> </dependency>
浏览 0提问于2018-02-12得票数 1
回答已采纳
1回答
当我尝试使用下面的命令启动动物园管理员时，我得到了下面的错误。zookeeper-server-start.bat config/zookeeper.properties
error missing 'server' jvm at 'C:\Program Files <x86>\Java
浏览 2提问于2018-08-17得票数 0
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号