apache-kafka 相关问题

Azure 架构注册表集成问题

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

kafka connect 不加载连接器

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

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

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

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

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

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

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

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

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

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

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

消费者ion Spring如何处理异常？

如何在Spring XML + Kafka App中进行错误处理？我正在使用 JSON 来生成和消费消息，但是当消费者获取垃圾数据时，它会运行无限循环。 这是我用过的 spring.xml ...

类 java.lang.String 无法转换为类 java.lang.Class （java.lang.String 和 java.lang.Class 位于加载程序“bootstrap”的 java.base 模块中）

我想扩展这里面临的进一步问题：设置构造函数时的 org.springframework.kafka.support.serializer.ErrorHandlingDeserializ' of type serializer.ErrorHandlingDeserializer]

在NiFi上如何区分来自两个不同Kafka的消息？

我有两个不同的应用程序，名为 A1 和 A2。每个应用程序都有自己的 Kafka 服务器。来自这两个 KAFKA 服务器（代理）的消息发送到 NiFi。 每个 Kafka 都有不同的主题名称...

Kafka 源连接器编码问题 | Oracle JDBC 连接器

我正在尝试使用 Kafka connect JDBC 连接器连接到 Oracle 服务器，这是我的连接器配置： 创建源连接器 hsr_source_connector2 和 （ 'connection.url' = 'jdbc:oracle:thin:@//

分布式跟踪不适用于 Spring WebFlux + Reactor Kafka

我使用Spring WebFlux，Spring boot版本是3.2.0。我使用原生 Reactor Kafka。 Spring boot Sleuth 已移至 Micrometer Tracing 您可以从这里阅读： Spring Cloud Sleuth 的最后一个小版本...

Apache Kafka 与 Redpanda 的性能测试

我目前正在物联网模拟场景中评估 Apache Kafka 与 Redpanda 的吞吐量和延迟。您能否建议如何为 Apache Kafk 设置性能测试环境...

Kafka幂等生产者

根据文档，幂等的 kafka 生产者维护一个序列号，确保事件的重复数据删除和排序。 这是否意味着在单个制作人会话中，

每个任务的 KafkaProducer 或单例 KafkaProducer

我有几个并行运行的任务（ExecutorService 和 Runnable 任务）。对所有这些都使用一个 KafkaProducer 实例（Spring singleton bean）是一个好的选择吗？在这种情况下，如何

org.springframework.kafka.support.serializer.ErrorHandlingDeserializ'类型为serializer.ErrorHandlingDeserializer]，同时设置构造函数参数

通过参考：How to handle the exception at Consumer in Spring XMl App?，我试图在 xml bean 中转换 Java bean 依赖关系并面临以下错误。 有人可以解释一下...

Kafka Consumer 无法间歇性解析监听器方法

我在卡夫卡消费者端遇到了下面的异常。令人惊讶的是，这个问题与旧版本的代码不一致（具有完全相同的配置，但有一些新的不相关...

Spring XMl App中consumer端如何处理异常？

如何在Spring XML + Kafka App中进行错误处理？我正在使用 JSON 来生成和消费消息，但是当消费者获取垃圾数据时，它会运行无限循环。 已在此处上传代码：https://

DI-kafkaMeter 发送消息错误

我使用jmeter DI-kafkaMeter向kafka发送消息 向 kafka 主题发送消息时出错：java.lang.RuntimeException：找不到 Kafka Producer Client。检查 KafkaProducerSampler 中的变量名称。 ...

Kafka 3.4，带有 Kraft，没有 Zookeeper，有 3 个经纪人

我需要 1 个 kafka 集群和 3 个 kraft borker。 我尝试使用下面的 docker 配置： 第一个经纪人的配置： 版本：“3” 服务： 卡夫卡-1： 图片：“bitnami/kafka：3.4.0” 主机...