Kafka Connect - 具有相同 Kafka 集群作为源的连接器？
Kafka Connect - Connector with same Kafka cluster as a source?
我只找到对 MirrorMaker v2 的引用。
我可以重用 org.apache.kafka.connect.mirror.MirrorSourceConnector 就好像它是一个以 Kafka 作为源的“普通”连接器一样，还是有其他东西，希望更简单，可用？
我正在尝试使用 KafkaConnect 及其 SMT（的组合）来模拟在其他消息代理中发现的消息路由行为。
例如，我想从一个主题中消费，从消息中提取值（headers 或负载），然后将消息路由到另一个主题 ] 相同的集群取决于消息中找到的数据。
谢谢
within the same cluster
这就是 Kafka Streams 或 ksqlDB 的用途。您可以直接通过代码导入和使用 SMT 方法，尽管您还需要使用连接转换器 类 来获取大多数 SMT 需要的 Schema/Struct 类型
虽然您可以使用 MirrorMaker，但集群间重定位不是它的目的
我只找到对 MirrorMaker v2 的引用。
我可以重用 org.apache.kafka.connect.mirror.MirrorSourceConnector 就好像它是一个以 Kafka 作为源的“普通”连接器一样，还是有其他东西，希望更简单，可用？
我正在尝试使用 KafkaConnect 及其 SMT（的组合）来模拟在其他消息代理中发现的消息路由行为。
例如，我想从一个主题中消费，从消息中提取值（headers 或负载），然后将消息路由到另一个主题 ] 相同的集群取决于消息中找到的数据。
谢谢
within the same cluster
这就是 Kafka Streams 或 ksqlDB 的用途。您可以直接通过代码导入和使用 SMT 方法，尽管您还需要使用连接转换器 类 来获取大多数 SMT 需要的 Schema/Struct 类型
虽然您可以使用 MirrorMaker，但集群间重定位不是它的目的