代码之家  ›  专栏  ›  技术社区  ›  hdjur_jcv

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

  •  0
  • hdjur_jcv  · 技术社区  · 5 年前

    我尝试了使用debezium connector for MS SQL的kafka connect转换谓词示例,并在kafka connect的文档中遇到了这个问题。两份文件中的例子都提到了错误的组织。阿帕奇。卡夫卡。连接谓词。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
    

    而在这两个发行版中,软件包是相同的:

    包裹组织。阿帕奇。卡夫卡。连接转变。谓词;

    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?

    0 回复  |  直到 5 年前
        1
  •  1
  •   Iskuskov Alexander    5 年前

    你说得对:这真的是个错误。

    对于Apache Kafka文档,我已经做了一个 fix ,但不知道为什么不适用(在公关中被问及)。

    使现代化修正将在2.8版中应用

    推荐文章