Apache 和 Confluent kafka 文档中 TopicNameMatches class 的错误包引用

Question

我尝试了 kafka connect transform predicate examples with debezium connector for MS SQL，并遇到了 kafka connect 文档的问题。两个文档中的示例都提到了错误的 org.apache.kafka.connect.predicates.TopicNameMatches，而不是正确的 org.apache.kafka.connect.transforms.predicates.TopicNameMatches:

http://kafka.apache.org/documentation.html#connect_predicates https://docs.confluent.io/platform/current/connect/transforms/regexrouter.html#predicate-examples

    predicates=IsFoo
    
    predicates.IsFoo.type=org.apache.kafka.connect.predicates.TopicNameMatches
    predicates.IsFoo.pattern=foo

而在两个发行版中包是相同的：

包 org.apache.kafka.connect.transforms.predicates;

https://github.com/a0x8o/kafka/blob/master/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java https://github.com/confluentinc/kafka/blob/master/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/predicates/TopicNameMatches.java

然后应该为两者发布用于文档改进的 KIP？

Answer 1

你是对的，真的错了。

对于 Apache Kafka 文档，我已经做了一个 fix，但不知道为什么它不适用（在 PR 中询问过）。

更新。修复将在 2.8 版本中应用

Apache 和 Confluent kafka 文档中 TopicNameMatches class 的错误包引用

Wrong package reference for TopicNameMatches class in both Apache and Confluent kafka documentation

apache-kafka

apache-kafka-connect

debezium

confluent-platform