使用bytearrayconverter作为键和值的jdbc接收器上的架构错误

whhtz7ly  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(367)

我正在尝试设置一个简单的jdbc postgresql接收器,将数据从一个kafka主题复制到我的postgresql示例。
我想简单地复制字节从一个Kafka主题到一个postgres表。不应涉及数据转换。
我正在使用这些转换器:

key.converter=org.apache.kafka.connect.converters.ByteArrayConverter
value.converter=org.apache.kafka.connect.converters.ByteArrayConverter

错误信息对我来说很奇怪: Sink connector 'MY_CONNECTOR' is configured with 'delete.enabled=false' and 'pk.mode=none' and therefore requires records with a non-null Struct value and non-null Struct schema, but found record at (topic='MY_TOPIC',partition=0,offset=664253924,timestamp=1602894844052) with a byte[] value and bytes value schema. 有什么问题吗?如果只涉及字节,为什么它会要求schema?
谢谢。

wztqucjr

wztqucjr1#

接收器不知道如何将字节数组解压到表列中。
因此,您将需要一个具有命名字段的结构,并且可以在其中指定bytearray值,假设列类型是blob

相关问题