-
Kafka生产者/消费者打开了太多文件描述符
我们有一个3节点的Kafka集群部署,其中包含5个主题,每个主题6个分区。我们已经配置了复制因子= 3,我 -
fetch.max.wait.ms与poll()方法的参数
在我问我的问题之前,我想指出一个类似的问题已经提出过<a href="https://stackoverflow.com/questions/50302119/apach -
如何为未命名的消费者组授权kafka负责人
我在kafka授权者日志中收到此类错误: <pre><code>Char(13) + CAST(@ER_No AS VARCHAR(8)) + ' is not a valid ER Number -
如何轮询kafka时间戳少于30秒的消息?
我只想轮询产生时间少于30秒的记录。在Kafka轮询中,有什么方法可以只消耗少于30秒的消息吗? -
Kafka客户端在Broker集群加载期间重新平衡
我提供了很多服务,在经纪人负担很重的情况下,Kafka客户会进行大量的重新平衡。这些经纪人由一个集 -
我如何为Kafka Consumer使用Dynamic主题
在Kafka的配置下找到服务器 @豆角,扁豆 public ConsumerFactory ConsumerFactory(){ 地图 -
有关分配偏移量时的错误的问题
我编写了一个Kafka使用者函数,该函数首先从读取的最后一个偏移量中检索消息,然后开始使用下一个偏 -
消费者何时提交补偿?
我正在使用spring-kafka-2.2.7-RELEASE。我正在使用@KafkaListener来创建我的使用者。 我已将enable.auto.commit -
Kafka配置min.insync.replicas不起作用
这是我早期学习卡夫卡的日子。而且我正在检查本地计算机上的每个kafka属性/概念。 所以我遇到 -
kafka-consumer-groups CLI未显示节点-kafka使用者groupf
我有一个在由node-kafka支持的node.js上运行的kafka消费者组。当此消费者组处于活动状态或非活动状态时, -
kafka主题中理想的分区数是多少?
我正在学习Kafka,并尝试为我最近的搜索应用程序创建一个主题。假定推送到kafka主题的数据数量很多。 -
kafka +开始偏移比之前的最后偏移高得多
我们正在使用具有3个kafka节点的kafka集群,其版本为<code>0.10</code> 从kafka日志中,我们收到一条非 -
spring kafka偏移量增量,即使自动提交偏移量设置为false
我正在尝试为<code>manual offset commit</code>上收到的消息实现<code>kafka</code>。我已将偏移量提交设置为<code>fa -
具有相同groupId的Spark Kafka流媒体将数据翻倍
我有一个Spark流作业,可以使用来自Kafka的数据,在Redis中保存偏移量,然后将结果保存在ElasticSearch中。 -
我想在python中为CSV数据编写流式Kafka API
让我们举一个例子,我有一个员工数据,并且必须编写producer.py和consumer.py(在python中通过kafka流)。 -
springframework.cloud.stream.messaging软件包中的Sink是什么?
我正在运行的应用程序将在kafka流中充当消费者。我有通过春季的流配置的kafka消息传递。 如何从 -
当Broker关闭,然后稍后恢复活动时,Kafka Consumer不会收到“旧-未成功提交”消息
我正在使用confluent.kafka dotnet Nuget软件包 Nuget版本1.2.1 操作系统:Windows 10 消费者配 -
有时,确实创建了具有唯一ID的使用者组,并且使用者没有分区就卡住了
使用者的配置如下。有时对于唯一ID,根本不会创建使用者组。我正在尝试根据应用程序名称使用消息。 -
如何配置kafka-console-consumer以读取单个消息并退出?
是否可以将<code>kafka-console-consumer</code>配置为从主题中读取一条消息然后退出? -
Google Cloud(GCP)发布/订阅支持的功能是否类似于Kafka中的ConsumerGroups
尝试在Google Cloud(GCP)发布/订阅与管理器Kafka服务之间做出选择。 在最新更新中,发布/订阅添加 -
如何将数据添加到Apache Kafka的分区中?
嗨,我正在研究卡夫卡。我正在尝试了解kafka的基础知识。我正在学习卡夫卡。我使用docker安装了kafka。 -
消费者群体如何在卡夫卡工作?
嗨,我正在研究kafka CLI,以清楚地了解kafka的工作原理。我对消费者群体感到困惑。我创建了具有三个分 -
Sprint引导kafka使用者无法连接到kafka容器
我正在尝试部署2个Spring Boot应用程序(kafka Producer和Consumer)。当我将Producer部署到docker时一切正常,但 -
读取多个主题的python Kafka使用者的使用率较低
我们有一个python消费群体,其中包含50个消费群体,这些消费群体分别来自10个主题和10个分区。 消费者 -
kafka服务器可以强制使用方属性吗?
我对卡夫卡世界比较陌生。我可以使用Java设置kafka使用者,并且可以看到使用者API允许我设置使用者属 -
卡夫卡消费者从一开始就不消费
我在本地计算机上安装了Kafka,并启动了zookeeper和一个代理服务器。 现在我有一个主题,内容如下 -
kafka流跳窗口聚合导致时间戳为零的多个窗口
Kafka Streams DSL窗口聚合导致多个窗口。 <pre><code>@StreamListener("input") public void process(KStream<S -
由于错误%!s(int32 = 1)]] /%!d(MISSING)放弃了经纪人%!d(MISSING),Filebeat无法流式传输到kafka
我有配置为的文件拍探矿器 <pre><code> prospectors: - type: log paths: /var/log/nginx/*e -
如果经纪人中不存在由kafka消费者指定的偏移量,该怎么办?
我是kafka的新手。我想了解不存在kafka使用者指定的偏移量时的行为。可能是由于保留策略或使用者指定 -
使用Flume从Kafka读取并写入Hbase时,我们面临着丢失的消息,无法跟踪问题
我们正在使用Apache Flume(kafka源,Hbase Sink,文件通道)从Kafka读取数据并写入Hbase。 Kafka:kafka源上有20个