apache-kafka
-
Kafka 获取错误 引导服务器中没有给出可解析的引导 URL 我很确定bootstrap.servers是正确的。Maven中有什么冲突或Kafka有什么问题吗? 在此之前,它已成功运行。我添加了一些Maven或Spark,然后出了点问题。 任何人都可以知道如何解决它吗? 这是java中
-
如何挑选卡夫卡 transaction.id 我想知道我能不能得到一些帮助来理解Kafka中的交易,特别是我如何使用 transaction.id。下面是上下文: 我的 Kafka 应用程序遵循以下模式:使用来自输入主题的消息,处理,发布到输出主题。 我
-
我们能否像RabbitMq一样,使用Apache Kafka拥有强大的路由能力? 我们正试图评估Kafka并替换我们软件中的Rabbit Mq。 我们知道Kafka在RabbitMq方面的优势,而不是离线消费,巨大的持久性,卓越的性能,低延迟和高吞吐量。 但是,我们需要 RabbitMq 具有的异构消
-
编写自定义 Kafka 序列化程序 我在Kafka消息中使用我自己的类,该消息具有一堆字符串数据类型。 因此,我无法使用默认序列化程序类或 Kafka 库附带的序列化程序类。 我想我需要编写自己的序列化程序并将其馈送到生产者
-
-
Kafka 使用者如何从多个分配的分区中消费 tl;博士;我试图理解分配了多个分区的单个使用者如何处理访问分区的消耗记录。 例如: 在移动到下一个分区之前完全处理单个分区。 每次处理每个分区中的可用记录块。 处理来自第一个可
-
使用Spring Embedded Kafka测试@KafkaListener 我正在尝试为我正在使用Spring Boot 2.x开发的Kafka听器编写一个单元测试。作为一个单元测试,我不想启动一个完整的Kafka服务器作为Zookeeper的实例。所以,我决定使用Spring Embedded Kafka。 我的听众
-
如何编写 Kafka 使用者 - 单线程与多线程 我写了一个单一的Kafka消费者(使用Spring Kafka),它从一个主题阅读,并且是消费者群体的一部分。使用消息后,它将执行所有下游操作并转到下一个消息偏移。我已将其打包为 WAR 文件,我的部
-
Kafka - 无法使用 Java 向远程服务器发送消息 我正在尝试创建一个群集以将消息发送到远程控件。我已经按照所述配置了所有内容。我在一台机器上运行这个,它使用shell工作正常。在我的Windows计算机上按照教程中所述编写Java代码后,我收
-
卡夫卡消费者。commitSync vs commitAsync 语录 缺点是,虽然 commitSync() 将重试提交,直到它成功或遇到不可重放的故障,但 commitAsync() 不会重试。 这句话我不清楚。我假设消费者向代理发送提交请求,如果代理在某个超时内
标签