我正在尝试使用以下命令启动kafka-connect:
connect-distributed /etc/schema-registry/connect-avro-distributed.properties
,但是我得到了:
[2017-02-15 12:45:35,962] INFO Instantiated task mysql-adventureworks-source-0 with version 3.1.2 of type io.confluent.connect.jdbc.source.JdbcSourceTask (org.apache.kafka.connect.runtim
我正在尝试设置一个本地kafka -连接堆栈与坞-撰写,我有一个问题,我的scala生产者,应该发送avro消息到一个卡夫卡主题使用模式注册表。
在我的生产者(scala)代码中,我执行以下操作:
val kafkaBootstrapServer = "kafka:9092"
val schemaRegistryUrl = "http://schema-registry:8081"
val topicName = "test"
val props = new Properties()
props.put("boots
在我们分发给工人的道具中,我们有:
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=<dev-schema-url>
我们已经注意到,当我们使用模式注册中心时,性能是不好的。如果没有模式注册中心,我可以使用AvroConverter吗?我试过,但我们遇到了:
java.io.IOException Not a data file
模式注册表是否与kafka连接器读取的每一条消息相联系?
模式缓存了吗?
在没有模式注册中心的情况下使用A
我正在使用带有MockSchemaRegistryClient的为我们的kafka系统构建一个集成测试。我正在为我们的一个Stream拓扑构建一个测试,该拓扑是使用Streams API (KStreamBuilder)构建的。此特定拓扑将KStream (stream1)送入KTable (table1)。
我在将来自表1的KTableProcessor的输入馈送到stream1时遇到错误:
Exception in thread "mortgage-kafka-consumers-it-c1dd9185-ce16-415c-ad82-293c1281c897-StreamThrea
我有一个由Kafka Connect创建的注册表架构。我还试图以编程方式发布到与模式相关的Kafka主题(使用TopicRecordNameStrategy),使用与我的Java应用程序中的注册表中存在的模式定义完全相同的模式定义,用例是自动重新发布延迟的消息。
因此,通过使用已经存在的确切模式,我是如何抛出异常的:
"Schema being registered is incompatible with an earlier schema; error code: 409"
模式是相同的,JSON比较已经证实了这一点