-
如何在同一主题上使用globalKtable和StateStore?
请澄清一下,我是Kafka的新手,很抱歉,如果我的问题似乎没有记载,我正在阅读教程,文档以及我能理 -
Kafka生产者/消费者打开了太多文件描述符
我们有一个3节点的Kafka集群部署,其中包含5个主题,每个主题6个分区。我们已经配置了复制因子= 3,我 -
有没有一种方法可以在kafka-console-producer.sh中添加标题
我想使用kafka-console-producer.sh触发一些带有Kafka标头的JSON消息。 这可能吗? <pre><code>firebaseUser.g -
更改为kafka_2.11
我已将pom文件中的Kafka版本从2.10更改为2.11,现在我遇到错误了 pom的变化 来自 <pre><code><depen -
如何轮询kafka时间戳少于30秒的消息?
我只想轮询产生时间少于30秒的记录。在Kafka轮询中,有什么方法可以只消耗少于30秒的消息吗? -
Apache Kafka分区保证中的消息顺序
阅读有关主题分区中的消息排序的本文:<a href="https://blog.softwaremill.com/does-kafka-really-guarantee-the-order-of-mes -
Kafka配置min.insync.replicas不起作用
这是我早期学习卡夫卡的日子。而且我正在检查本地计算机上的每个kafka属性/概念。 所以我遇到 -
kafka主题中理想的分区数是多少?
我正在学习Kafka,并尝试为我最近的搜索应用程序创建一个主题。假定推送到kafka主题的数据数量很多。 -
kafka +开始偏移比之前的最后偏移高得多
我们正在使用具有3个kafka节点的kafka集群,其版本为<code>0.10</code> 从kafka日志中,我们收到一条非 -
Kafka是否提供生产者水平补偿?
假设,我有多个Kafka生产者同时为一个Kafka主题生产数据。 是否有可能获得给定生产者生产的最后 -
我想在python中为CSV数据编写流式Kafka API
让我们举一个例子,我有一个员工数据,并且必须编写producer.py和consumer.py(在python中通过kafka流)。 -
如何通过Kafka Producer发送Protobuf消息
我正在使用Sarama库通过生产者发送消息。 这使我可以发送字符串。我的目标是发送Protobuf消息 <pre><co -
卡夫卡生产者在微服务中造成的巨大GC暂停
我的一个Web服务针对每个在线请求将日志消息(大小:10K)发送到kafka(版本:0.10.2.1),并且我发现Kafk -
Kafka Producer JMX指标缺失
我们已经在OKD(支持Red Hat OpenShift的Kubernetes的Origin社区发行版)上部署了Spring Boot应用程序。没有devops团 -
无法解决错误:java.io.NotSerializableException:org.apache.avro.Schema $ RecordSchema
我正在尝试通过SparkSession从表中读取数据,并将其发布到Kafka主题。使用下面的代码来实现同样的效果: -
如何将消息远程发送到kafka
我对卡夫卡很陌生。我正在尝试从本地机器生产商向kafka服务器发送消息。我无法弄清楚问题所在或正在 -
为什么我将kafka服务器从0.8.2升级到0.10.2.2后生产者的借贷增加
我遵循了Apache Kafka的升级文件。 <ol> <li>设置inter.broker.protocol = 0.8.2并重新启动集群</li> <li>升级jar && b -
卡夫卡消费者从一开始就不消费
我在本地计算机上安装了Kafka,并启动了zookeeper和一个代理服务器。 现在我有一个主题,内容如下 -
为什么org.apache.kafka.common.errors.TimeoutException:抛出60000 ms后无法更新元数据?
我的kafka经纪人(单人)运行大约一个月或多或少都很平稳,但是在某个时候,当我的生产者(spring应用 -
可以与Zookeeper对话,但不能与消息代理对话 如何诊断
我正在使用kafka-python为Kafka 2.2.1集群(AWS的MSK服务中的托管集群实例)生成消息。我能够检索引导服务器 -
如果经纪人中不存在由kafka消费者指定的偏移量,该怎么办?
我是kafka的新手。我想了解不存在kafka使用者指定的偏移量时的行为。可能是由于保留策略或使用者指定 -
生产者初始化事务时获取TimeoutException
我想在Kafka中配置手动提交。以下代码表示我的使用者和生产者的配置: <pre><code>Properties consumerProps -
当发送有关kafka主题的消息时,为什么线程要花很长时间等待?
我正在使用kafka-spring发送有关kafka主题的消息。消息已正确发送到主题,但是线程在调用发送消息后花了 -
Kafka主题中丢失的消息
尝试使用<a href="https://kafka.apache.org/11/javadoc/org/apache/kafka/clients/producer/ProducerRecord.html" rel="nofollow noreferrer" -
将有关单个Kafka主题的消息分发给特定消费者
有关单个Kafka主题,单个分区的Avro编码消息。这些消息中的每一个仅由特定使用者使用。例如,关于该 -
Min.insync.replicas的NotEnoughReplicasException的异常行为
这是<a href="https://stackoverflow.com/questions/58780219/kafka-configuration-min-insync-replicas-not-working">my previous question</a> -
为灾难恢复服务器设置Kafka镜像时丢失消息
<strong> Producer.config </strong> <pre><code>key.serializer=org.apache.kafka.common.serialization.StringSerializer value.serializ -
无法使用pykafka发送消息
我正在使用pykafka,可以获取主题名称,但无法发送消息。我的代码如下所示 <pre><code>grep -l cookie *.js -
有没有办法找出Kafka进行数据序列化所花费的时间
我想确定Kafka序列化不同数据格式所花费的时间。并且怀疑我是否可以这样做(因为我认为这是在Kafka方 -
服务器在收到响应之前已断开连接。现在要请求元数据更新
我的kafka服务器已启用<strong> SSL </strong>,分区数为6。这是一个代理设置。 以下是我的生产者配置