apache-kafka 相关问题

Kafka Streams 和 CompletableFuture（或异步 java api）

我正在研究 Apache Kafka Stream SPI。我想知道是否有一种方法可以在 mapValues 方法内部执行异步代码。例如从外部存储检索数据。有没有办法整合...

带有 Confluence.Kafka 的 Azure 事件中心。我可以生产但不能消费

我正在努力解决一个我无法理解的问题。 通过这个配置，我可以成功生成一条消息； var config = 新的 ProducerConfig { BootstrapServers = bootstrapServers, ...

Kafka KRaft：三分之一的经纪人总是宕机

我正在尝试使用 KRaft 创建一个集群，其中有 3 个代理和 3 个控制器。但每次当一个经纪商下跌时，前一个下跌的经纪商就会上涨。 这是我的码头配置； 版本...

如何提取 Kafka Streams 中消息中嵌入的时间戳

我想提取每条消息中嵌入的时间戳并将它们作为 json 有效负载发送到我的数据库中。 我想获得以下三个时间戳。 事件时间：事件发生的时间点...

Kafka 中消费者组协调员和消费者组领导者有什么区别？

我看到了对卡夫卡消费者组协调员和消费者组领导者的引用...... 有什么区别？ 将集团管理分为两组不同的好处是什么

适用于 Kafka 的 Oracle GoldenGate 适配器 - JSON 消息内容

在我的kafka金门大数据中。当我尝试更新记录时，我只在 json 文件的后面部分中获取更新的列和主键列 {“表”：“MYSCHEMATOPIC.PASSPORTS”，“op_type...

Spring-Boot 记录到 Kafka：如何消除警告；最佳实践

我被问及如何从 Oozie 中作为 Java 操作运行的 Spring Boot 应用程序捕获日志输出。 我最初的想法是可以编辑一些 log4j 属性以...

GKE 上的 Strmzi 0.26.0（版本 - 1.30.5-gke.1014001）- 未找到 poddisruptionbudgets

我们在 GKE 上部署了 Strimzi 0.26.0（版本 - 1.30.5-gke.1014001） 资源 - Kafka、KafkaBrodge、KafkaUser 现在显示错误，原因是 - 未找到 poddisruptionbudgets kubectl 描述 kafka ...

使用动态加载的证书在 Spring 中设置与 Kafka 的 mTLS 连接

我正在开发一个 Spring Kafka 项目，该项目使用以下库 org.springframework.kafka:spring-kafka:3.0.12 连接到 Kafka 服务器。它使用来自

蟒蛇。 kafka raft 连接到控制器

我想连接到端口 9093 上的 kraft 控制器（非代理）。我无法连接 代码示例： #!/usr/bin/env python3 从 confluence_kafka.admin 导入 AdminClient 导入 json 导入操作系统

在消费者上反序列化自定义消息

我正在尝试 Spring Cloud Stream 和 Kafka，并在我认为是一个简单的问题上进行了思考：消费者的简单消息反序列化。 我有以下 Spring 配置： 克洛...

为kafka主题编写标题

我有这个玩具FlinkSql应用程序，输入中有一个kafka主题，并且想要输出到另一个kafka主题。 （出于某种原因，我使用 upsert-kafka 连接器。） 我想更新/创建标题...

使用 SSL 的 Kafka - 写入主题 - 授权错误

我正在尝试从命令行生成启用了 SSL 的本地 Kafka 集群上的主题。 主题刚刚创建： kafka-topics --zookeeper localhost:2181 --create --topic sim...

Kafka消费者如何反序列化生产者发送的dto对象？

我正在使用spring向kafka消费者发送消息。 this.kafkaTemplate.send(applicationProperties.getKafka().getTopics().getNoticeGenerationEventsTopic(), japser姓名，

Kafka 连接 SqlServer 配置（SSL）

我有一个 JdbcSourceConnector 连接器，尝试使用 url 中的下一个配置“encrypt=false;trustServerCertificate=false;”连接到 SQL Server 数据库因为它很旧

命名kafka主题的最佳实践是什么？

我们是 kafka 的新手，我们有几个团队正在开发一些相互发布/订阅事件的应用程序。由于 kafka 主题名称将在团队之间共享，因此...

如何在Minikube中运行Kafka-Connect？

要运行 cp S3-connect 以在本地 Mac 中使用 kafka 主题，我做了如下操作 1.安装Confluence Kafka连接器并运行kafka connect-standalone.sh ML-C02Z605SLVDQ:kafka_2....

如何在kafkajs中检查kafka生产者是否连接

我有一个nodejs 服务，可以处理AWS lambda 函数中提供的https 请求。我在服务中使用 KafkaJs，并在容器级别初始化生产者。我不想

如何创建同步Kafka队列进行预订？

我正在尝试为需要处理大量请求/秒的预订系统创建（纸质）系统架构。 我的想法是使用 Kafka 来处理队列和优先级，但似乎......

如何获取kafka中未提交的消息

我在java中有一个函数，我试图在其中获取未读的消息。例如，如果我在代理中有offSet 0,1,2 的消息已被消费者读取，并且如果我切换...