Apache和Confluent kafka文档中对TopicNameMatches类的包引用都是错误的

Question

我尝试了使用用于MS SQL的debezium连接器的kafka connect转换谓词示例，并使用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版中应用