我有一个简单的应用程序，它将使用来自 topicA 和 topicB 的两个流，将它们转换为 KTables，然后使用外键连接两个表。然后，将联接的结果发送到输出主题。在本地环境中，应用程序运行良好，...

我在Spring Boot应用程序中使用Kafka生产者。 @Component public class MessageProducer { @Value("${topic.name}") ...

我正在使用 debezium kafka connect 将 postgresql 数据库 CDC 事件流式传输到 kafka 集群。目前，我使用的是 1.9.0 版，但想升级到 2.4.0 版 我...

我正在尝试做两件事。 使用 python boto3 API 列出 MSK 主题，但在 boto3.client（“kafka”） 中找不到 API 此外，我正在尝试使用相同的 python bot...

目标 目标是创建一个 Snowflake 存储过程，该过程每天使用 Kafka 主题中的消息一次，处理这些消息，然后将处理后的数据加载到 Snowflake 表中以供进一步分析。 错误描述： 遇...

您能解释一下我应该在哪里获得以下代码中缺少的属性吗？ （SMTH应在LSAT线路中） KafkaProperties prop = new KafkaProperties(); KafkaPrope...

我正在使用生产者属性，如下所示spring-kafka key-serializer: org.apache.kafka.common.serialization.StringSerializer ...

在 Spring Kafka 中，我有两个 Kafka 听众在听同一个主题。我希望两个侦听器都有自己的重试和死信主题，因此如果一个侦听器发生故障，它不会重播给另一个侦听器。使用以下配置，它们最终都将使...

如何通过涉及 400+ 并发更新的增量共享以流式处理方式读取多个架构。 DLT 似乎对管道上的 100 个并发更新有限制。最初，我想在单个管道中创建多个独立的流。kafka 还是 Kinesis 更...

我们有两个微服务和 .请求将被发送到，一旦获得批准，资金将被转移。在提交批准期间，会有一个 from to 的回调，根据该回调进行转移。transferapprovaltransferapproval...