我正在使用 Kafka Connect 3.4.0，遇到了一个我很难理解的问题。我有日志显示 Kafka Connect worker 在启动期间无法从配置主题中读取会话密钥。奇怪的是，恰好一个小时后...

我正在尝试将日志从 log4j2 流式传输到 Kafka 的主题。 我的 zookeeper 和 kafka 服务器正在运行。我已经为此创建了一个主题。 Unable to write to Ka...

设置 spark.streaming.kafka.maxRatePerPartition：100 并摄取 10000 条记录，每秒应需要 100 条记录， 但消耗了所有 10000 条记录...

我有两个 Kafka 流。 例如，第一个 - 没有键，但我们有一个（非唯一，考虑到消息速率）时间戳。1,3,5,7,9 第二个，例如： - 即某物为第一个主题中的值分配了一个键，并且（可逆地）更改...

我想同时使用两者，并在单个 Ubuntu 服务器上运行它们。confluent/kafkaconfluent/zookeeper 我正在使用以下配置： docker run -e ZOOKEEPE...

我正在使用 kafka 在 Spring boot 上做一个机器人电报，我正在 Inteligi IDEA 中构建一个项目，一切都很好，但是一旦我尝试运行 jar 文件，错误就会崩溃，我在下面提供日志...

我有一个包含损坏消息的旧主题，我需要完全重新处理该主题，忽略无法处理的消息。对于此方案，哪种正确的未捕获异常处理策略？ 我无法完全理解 KStreams 应用程序上未捕获异常处理的 REPLACE_...

我使用 spring boot 版本 2.5.3、spring-cloud-stream-binder-kafka-stream 版本 3.1.3 和 kafka-clients 版本 2.8.0。我...

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

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