apache-kafka 相关问题

Apache Kafka是一个分布式流媒体平台，用于存储和处理高吞吐量数据流。

自定义 DefaultErrorHandler 未在多个绑定 kafka 中被调用

我有一个spring cloud kafka绑定消费者服务。主要消费者主题和 dlq 消费者位于不同的经纪人中。因此我需要创建多个绑定。我面临的问题...

apache-kafka spring-cloud spring-cloud-stream

回答 1 投票 0

Confluence Kafka Timestamp Converter 值问题

我使用 Apache Kafka 和 Confluence Connect v7.3.2 平台以及部署为 Sink Connector 的 MongoDB 连接器，以便将具有 2 个时间戳字段的消息流式传输到集合中。这些值

mongodb apache-kafka timestamp type-conversion mongodb-kafka-connector

回答 1 投票 0

Kafka createTopics 失败

我是 Kafka 新手，我正在尝试使用命令行创建一个主题，但出现以下错误： C:\kafka in\windows>kafka-topics.bat --create --topictutorialspedia --boot...

apache-kafka spring-kafka apache-zookeeper apache-kafka-connect kafka-topic

回答 2 投票 0

当复制的broker之一宕机时，kafka是否会维持复制因子

我在本地计算机的集群中运行三个代理，id 为 (0, 1, 2) 我创建一个主题，其中一个分区的复制因子为 2 因此，副本分布在经纪人之间例如 br...

apache-kafka rebalancing

回答 1 投票 0

@Profile 不适用于@KafkaListener

我使用了@Profile（“Training”）和@KafkaListener，即使传递随机配置文件，KafkaListener也正在工作。仅当配置文件匹配时才工作 @Profile(“训练”...

java spring spring-boot apache-kafka

回答 1 投票 0

原因：java.lang.IllegalStateException：标头中没有类型信息且未提供默认类型

在我的项目中，我们使用 Spring XML 配置（目前没有范围使用 Spring Boot），我希望通过良好的异常处理和重试机制来实现 Kafka 消费者。另外，也想

java spring apache-kafka spring-kafka

回答 1 投票 0

重新连接到同一个消费者组后仅读取来自 Kafka 的新消息

我们假设这样一种情况：有一个 Java Spring 应用程序，它从 Kafka 读取消息（客户组：MyGroupName）。消息出现在 Kafka 上：msg_1、msg_2、msg_3 应用程序读取我的信息...

java apache-kafka

回答 1 投票 0

我的 kafka 消费者客户端无法在我的 Mac 上运行，为什么？

嗨：我是 kafka 新手，我按照以下步骤在我的 mac 上安装和初始化 kafka：酿造安装卡夫卡我可以看到配置文件是： /usr/local/etc/kafka/server.properties /usr/local/etc/

macos apache-kafka

回答 2 投票 0

org.apache.kafka.common.errors.InconcientGroupProtocolException：组成员支持的协议与现有协议不兼容

我正在尝试使用 spring-boot 应用程序连接到 kafka 主题，但收到此错误： org.apache.kafka.common.errors.InconcientGroupProtocolException：支持组成员

java apache-kafka

回答 2 投票 0

Strimzi 将容器加载到 aws ecr - 检查推送权限时出错

我通过 Strimzi 运算符在 Kubernetes 上运行 Apache Kafka。我正在尝试使用 mysql debezium 连接器安装 Kafka Connect。这是连接器配置文件： api版本：kafka.strimzi...

docker kubernetes apache-kafka apache-kafka-connect amazon-ecr

回答 2 投票 0

由于致命异常而退出 Kafka (kafka.Kafka$)

~/kafka$ bin/kafka-server-start.sh config/server.properties SLF4J：类路径包含多个 SLF4J 绑定。 SLF4J：在 [jar:file:/home/boitran/hive/lib/log4j-slf4j-impl-2.17.1.jar 中找到绑定！...

apache-kafka

回答 2 投票 0

Azure 架构注册表集成问题

我正在开发一个Springboot应用程序，它使用Spring-kafka来实现Kafka Producer以将消息发送到Kafka集群。在第一次迭代中，我们在 AKS 中部署了 Spring 应用程序

spring-boot azure apache-kafka spring-kafka confluent-schema-registry

回答 1 投票 0

kafka connect 不加载连接器

我正在使用以下 dockerfile 在我的 kafka-connect 映像中加载 mysql 连接器。来自 eclipse-temurin 运行 mkdir -p /opt/kafka/bin /opt/kafka/libs /opt/kafka/config /opt/kafka/logs 复制./kafk...

apache-kafka apache-kafka-connect

回答 1 投票 0

组 ID 未注册的应用程序信息 kafka.consumer

我在使用 Spring Cloud Stream 的 Kafka 消费者服务的日志中多次看到这个特定的日志“App info kafka.consumer for group-id unregistered”。我无法理解...

java spring-boot apache-kafka kafka-consumer-api spring-cloud-stream

回答 1 投票 0

如何从Kafka Stream变更日志主题读取数据？

我使用Kafka Stream来处理我的主题A，并使用inMemoryKeyValueStore。 builder.addStateStore(Stores.keyValueStoreBuilder( //Stores.persistentKeyValueStore("AccurateADCounts"), ...

apache-kafka apache-kafka-streams

回答 1 投票 0

Kafka Producer - Spring Boot 应用程序 - 无法生成消息

我也在学习Spring Boot和Kafka。我进行了一些探索并配置了一个示例生产者应用程序，如下所示。但是我无法发布这些消息。如果我能得到那就太好了

java spring-boot apache-kafka spring-kafka kafka-producer-api

回答 1 投票 0

反应式kafka非阻塞背压的任何示例

需要反应式kafka非阻塞背压的java代码示例。根据[文档]，Reactor Kafka API 受益于 Reactor 提供的非阻塞背压。有没有什么工具...

java spring-boot apache-kafka reactive reactive-kafka

回答 1 投票 0

如何在从 kafka-snowflake 接收器连接器连接时禁用雪花 OCSP 验证

我们正在尝试使用接收器连接器将数据从kafka主题推送到雪花。但我们无法创建连接器并看到以下警告严重：警告！！！使用故障打开进行连接。