有一个旧服务将值写入数据库。 我需要将值转换为事件，然后将其发送到 kafka。 我将创建一个服务，一旦在固定延迟中检查新记录并发送它们，还将提交的记录 ID 写入技术表，但也许还有其他方法、最佳实...

我已经遵循了这个演示并收到以下错误。 https://github.com/confluentinc/cp-demo https://github.com/confluentinc/cp-demo/...

我有一个用例，我需要在所有服务实例中使用消息。假设我的服务在 5 个实例上运行，那么通过 Kafka 传来的消息需要在每个实例上处理。由于这些数据被用于许多其他 API，因此我们将其存储在本地内存中以...

嗨，我正在尝试了解 kafka 连接变压器和转换器的流程。 我正在使用带有 xml 转换器的 fileStream 源连接器来强制执行 xsd 中的架构。当我使用转换器作为字符串时，我能够解析消息，...

我正在使用 kafka 发布连接器，该连接器正在发布通过邮递员提供的有效负载。现在，有一个 kafka 侦听器，它监听该主题中的消息（它只有 1 个分区）。在同一个 kafka 侦听器流中，有一个 s...

我正在使用 akhq 与 kafka 进行可视化。我的记录中有一些属性需要在 akhq 中屏蔽。我使用了数据屏蔽配置（来自文档：https://akhq.io/docs/configuration/a...

我正在使用 velero restic 来备份和恢复部署在 GKE 集群中的 kafka。 我在 Kafka 命名空间中部署了 kafka，我正在尝试进行整个命名空间备份。 备份已完成。当我在另一...

当我使用 kafka-producer-perf-test.sh 模拟生产者向具有 2 个分区的主题“t”发送 10,000 条消息，并使用下面提到的设置为 3 的消费者代码时，我观察到，当使用消息编...

我正在对 Kafka 进行性能测试，需要测试不同的大型模式。目前，我正在进行基于 Avro 的负载测试。 通常，在使用 Kafka 时，您拥有数据并从中生成架构。在此方案中，我必须测试多个架构，我不...

我希望有一系列小型的独立服务，这些服务要么使用 Kafka 主题并将数据输出到不同的系统中，要么相反：从系统接收数据并生成 Kafka 消息。对于这样的应用，正确的方法是什么？ 示例 1：将 SQL...