apache-kafka - 尝试使用融合在 Kafka 中创建主题正则表达式

问题描述

我正在尝试使用 confluent 为主题创建一个正则表达式。根据文档，我不能同时给出主题和主题正则表达式（这很有意义），但是当我给出正则表达式时，它给了我以下错误。

Missing required configuration "topic" which has no default value. You can also find the above list of errors at the endpoint `/connector-plugins/{connectorType}/config/validate

以下是连接器的属性：

{
  "name": "localMongoSink",
  "connector.class": "com.mongodb.kafka.connect.MongoSinkConnector",
  "topics.regex": "^digest",
  "connection.uri": "mongodb+srv://nitinkapoor:admin@cluster0.7mxo4.mongodb.net/test",
  "database": "result"
}

非常感谢您的投入。

最好的问候 Nk

标签： apache-kafkaapache-kafka-connectconfluent-platform

apache-kafka - 尝试使用融合在 Kafka 中创建主题正则表达式

问题描述

解决方案

推荐阅读