我如何最好地将连接器添加到Docker Compose中的Kafka Connect
现在，我有一个Docker组成，可以创建Kafka群集和Kafka Connect。它还创建了一个shell容器，我用它来发送带有配置的POST以添加新连接器。如何设置Docker组合以添加连接器（使用我的配置）AFTER Kafka Connect已准备就绪？ 阅读全文
docker apache-kafka apache-kafka-connectKafka连接连接器如何知道要使用哪种架构
假设我有很多不同的主题，每个主题都有自己的JSON模式。在模式注册表中，我指出了哪些模式存在于不同的主题中，而不是直接提到该架构适用的主题。然后，在我的水槽连接器中，我仅指架构注册表的端点(URL）。因此，据我所知，我从未指出应使用哪个注册架构KAFKA... 阅读全文
apache-kafka apache-kafka-connect confluent-schema-registry如何实施消耗外部Kafka数据并写入我们的AWS RDS的过程
我正在实施客户管理解决方案，并从许多来源（例如游戏平台，CRM/marketing工具等）接收数据，并将其合并到SQL Server内置的标准数据仓库中。它可能会根据客户端，数据提供商或需求（定期基础(daily/hourly/etc)的平面文件，VIS... 阅读全文
apache-kafka apache-kafka-connect