我们在集群中有3 kafka机器和3动物园管理员服务器和3模式注册中心服务。当我们在卡夫卡机器上启动模式-注册表服务时,我们从模式-注册表日志中得到以下信息Unable to subscribe to the KafkaTopic may not exist我们检查所有主题的列表,并看到主题- _schemas。
因此,
我已经创建了一个NiFi流,它最终将json记录发布为带有Avro编码值和字符串键的记录,使用模式中的模式。这是 in NiFi。我现在试图使用Kafka (connect-standalone)使用JdbcSinkConnector将消息移动到PostgreSQL数据库,但得到了以下错误:bootstrap.servers=localhost:29092key.converter=org.apache.kafka</
有人能帮我解决这个问题,正确地连接两个关键和值为GenericRecord的流吗?首先,正如您所看到的,我使用AVRO模式为键和值创建了两个主题。之后,我将加入这两个流,并在输出主题中创建新的GenericRecord,这是一个所谓的带有投影模式的投影记录,我得到了异常,如代码片段后面所示:public void joinKStreamToKStreamWhereKeyValueIsGenericRecordGenericRecord:72)
at io.confluent.kafka</em