-
为什么createDirectStream仅创建一个使用者? (这导致可用性低!!)
我在Spark流中使用<strong> kafkaUtils.createDirectStream()</strong>。 这种方法将帮助我创建一个组的kafka使用者 -
如何在同一主题上使用globalKtable和StateStore?
请澄清一下,我是Kafka的新手,很抱歉,如果我的问题似乎没有记载,我正在阅读教程,文档以及我能理 -
将REST代理连接到Confluent Cloud尝试连接到Zookeeper
我正在尝试将kafka rest代理连接到融合云。 <pre><code>kafka-rest-start ccloud-kafka-rest.properties </code></pre> -
无法在Windows 10上启动Kafka服务器-Kafka的日志目录(和子目录)应仅包含Kafka主题数据
按照<a href="https://www.udemy.com/course/apache-kafka/learn/lecture/11566904#overview" rel="nofollow noreferrer">lesson 28 of Learn Ap -
当我使用Kafka Streams时,我很困惑,如何指定要消费的topic-partition的偏移量?
例如。我有一个主题“ test”,带有4个分区。当我启动流应用程序时,过了一段时间,应用程序崩溃了 -
Kafka生产者/消费者打开了太多文件描述符
我们有一个3节点的Kafka集群部署,其中包含5个主题,每个主题6个分区。我们已经配置了复制因子= 3,我 -
如何使用Kafka数据源指定流查询的Kafka自定义配置(例如Confluent Cloud身份验证)?
我想使用针对Confluent Cloud的结构化流进行读写。问题是我无法在文档中找到进行身份验证的方法。 < -
将JSON数据从COBOL程序发送到KAFKA REST服务器
当我尝试从COBOL程序发送到KAFKA时,JSON数据中缺少“方括号” 我已经启动了KAFKA-REST服务器,并尝 -
在执行纱线应用程序终止并再次运行之后,flink将从上一个偏移量恢复吗?
我使用FlinkKafkaConsumer来使用kafka并启用检查点。现在,我对偏移量管理和检查点机制有些困惑。 我已经 -
如何使用WSO2ESB中的标头将值从发布者传递给订阅者
我想将值从WSO2发布者传递给订户,好像该值是经过硬编码的,其工作原理一样,但是如果尝试使其动态 -
Avro模式不符合我的json数据?
我正在生成json消息,并尝试使其符合Avro标准。这是我要发送的消息的示例,但是我收到以下错误,我认 -
如何在JDBC Source Connector中设置开始偏移以从Kafka中的MySQL表获取所有数据
我已经使用Kafka Connect添加了JDBC Source Connector,它是从MySQL表中获取数据。 连接器已成功添加,并 -
在Landoop kafka UI中哪里可以找到kafka消息标题?
我正在尝试将一些消息以及一些自定义标头发布到kafka。但是我在Landoop Kafka UI中看不到这些标题详细信 -
Kafka Connect在时间戳模式下-如何追加到查询末尾?
我有一个已配置的源连接器,可从DB2检索并使用时间戳记模式。例如: <pre><code> "name": "my -
fetch.max.wait.ms与poll()方法的参数
在我问我的问题之前,我想指出一个类似的问题已经提出过<a href="https://stackoverflow.com/questions/50302119/apach -
无法使用Kafka消息
我设置了一个具有1个分区和1个复制因子的Kafka代理。 我可以产生消息,但是我不能使用它们。我没有收 -
单元测试KafkaListenerErrorHandler
我有一个测试监听器: <pre><code>@KafkaListener(topics = TEST_TOPIC) public void consume( ConsumerRecord<String, -
如何构建融合的卡夫卡消费者?
我正在使用<a href="https://github.com/confluentinc/confluent-kafka-go" rel="nofollow noreferrer">confluent-kafka-go</a>来写kafka -
/kafka_2.11-2.1.1/kafka_2.11-2.1.1/bin/kafka-run-class.sh:第306行:C:\ Program:没有此类文件或目录
我正在尝试在Windows中启动kafka代理。我的系统中运行了Zookeeper。 使用的命令 <pre><code>./bin/kafka-server-s -
消息队列(例如RabbitMQ)还是用于微服务的Kafka?
我们正在启动一个新项目,我们在此评估用于微服务之间异步通信的技术堆栈吗?我们正在为此考虑使 -
如何为未命名的消费者组授权kafka负责人
我在kafka授权者日志中收到此类错误: <pre><code>Char(13) + CAST(@ER_No AS VARCHAR(8)) + ' is not a valid ER Number -
API版本= 1时的Kafka群集问题
当我使用具有3个节点且Kafka API版本= 1的Kafka集群时 我收到以下错误代码= 16 如果代理收到不是其协 -
KafkaJS生产者SSL证书
我正在用KafkaJS编写NodeJS Kafka生产者,并且在理解如何获取所需的SSL证书以使用SASL-SSL连接连接到Kafka时遇 -
开窗后,Kafka Stream Suppress不产生输出
我正在窗口中查看流环境中的传入对象,并进行收集和打印。 使用kafka抑制可避免出现中间结果。 <p -
线程'kafka-producer-network-thread中未捕获的异常|生产者1
生成卡夫卡后,未捕获的异常发生在日志中。但是成功地生产了卡夫卡饲料。我想了解为什么出现此日 -
本地是否支持kafka SSL连接?
我不会在quarkus中使用smallrye-kafka使用SSL连接到kafka主题。 我的代码在执行<code>mvn compile quarkus:dev</co -
连接到AVRO架构注册表的SerializationException
我有4个使用者3个在kafka客户端的0.10.0.0版本上,但是其中一个已经移至2.0.0版。 当我调用RestService. -
使用Spark和Elastic Search时在Kafka中存储偏移量的正确方法
我对此进行了大量研究,但仍然无法找到合适的方法。无论走到哪里,我都发现最简单的方法是调用<code -
KIP-500:用自我管理的元数据仲裁替换ZooKeeper
您好,我们需要了解KIP-500的状态:用自我管理的元数据仲裁替换ZooKeeper 如果有什么办法可以解决这个用 -
2个节点出现故障后,kafka不再选举新领导人
我们在3个kafka节点的环境中测试了scalein 每个人都有一个经纪人和动物园管理员服务 复制品.factor = 2 服