作者热门文章
- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我创建了最简单的 kafka sink 连接器配置,并且我使用的是 confluent 4.1.0:
{
"connector.class":
"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
"type.name": "test-type",
"tasks.max": "1",
"topics": "dialogs",
"name": "elasticsearch-sink",
"key.ignore": "true",
"connection.url": "http://localhost:9200",
"schema.ignore": "true"
}
在主题中,我将消息保存在JSON
{ "topics": "resd"}
但结果我得到一个错误:
Caused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id -1 Caused by: org.apache.kafka.common.errors.SerializationException: Unknown magic byte!
最佳答案
正如 cricket_007 所说,您需要告诉 Connect 使用 Json 反序列化器,如果这是您的数据所采用的格式。将其添加到您的连接器配置中:
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable": "false",
"key.converter": "org.apache.kafka.connect.json.JsonConverter",
"key.converter.schemas.enable": "false"
关于apache-kafka - ElasticsearchSinkConnector 无法将数据反序列化为 Avro,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50182754/
使用 kafka-lenses-dev图像,我在将 Kafka 连接到本地 Elasticsearch 7.1.1 实例时遇到了问题。如您所见,连接被拒绝,尽管实例已启动并正在运行并且可以将文档卷入其
我创建了最简单的 kafka sink 连接器配置,并且我使用的是 confluent 4.1.0: { "connector.class": "io.confluent.connect.el
我是一名优秀的程序员,十分优秀!