我正在尝试设置一个简单的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?
谢谢。
1条答案
按热度按时间wztqucjr1#
接收器不知道如何将字节数组解压到表列中。
因此,您将需要一个具有命名字段的结构,并且可以在其中指定bytearray值,假设列类型是blob