I’m using the below s3 sink connector for topic backup but when i restore this using source connector I don’t see keys and headers in the kafka ui.
Can anyone help thanks.
Sink Connector
connector.class=io.lenses.streamreactor.connect.aws.s3.sink.S3SinkConnector connect.s3.aws.client=AWS aws.region=ap-southeast-2 connect.s3.custom.endpoint=https://s3.ap-southeast-2.amazonaws.com/ connect.s3.aws.region=ap-southeast-2 tasks.max=1 topics=soruce_topic schema.enable=true connect.s3.kcql=insert into some_bucket:topic-backup-as-avro-with-schema SELECT * FROM soruce_topic STOREAS Avro WITHPARTITIONER=KeysAndValues WITH_FLUSH_COUNT=1 value.converter.schemas.enable=true value.converter=io.confluent.connect.avro.AvroConverter value.converter.basic.auth.credentials.source=USER_INFO value.converter.basic.auth.user.info=u:pwd value.converter.schema.registry.url=[https://url](https://url/) errors.log.enable=true store.kafka.keys=true store.kafka.headers=true key.converter.schemas.enable=false key.converter=org.apache.kafka.connect.storage.StringConverter
Source Connector
connector.class=io.lenses.streamreactor.connect.aws.s3.source.S3SourceConnector connect.s3.aws.client=AWS aws.region=ap-southeast-2 connect.s3.custom.endpoint=https://s3.ap-southeast-2.amazonaws.com/ connect.s3.aws.region=ap-southeast-2 tasks.max=2 topics=msk.restore.test.target.topic.v2 schema.enable=true connect.s3.kcql=insert into msk.restore.test.target.topic.v2 SELECT * FROM some_bucket:topic-backup-as-avro-with-schema STOREAS Avro WITHPARTITIONER=KeysAndValues WITH_FLUSH_COUNT = 1 value.converter.schemas.enable=true value.converter=io.confluent.connect.avro.AvroConverter value.converter.basic.auth.credentials.source=USER_INFO value.converter.basic.auth.user.info=u:pwd value.converter.schema.registry.url=[https://url](https://url/) errors.log.enable=true store.kafka.headers=true key.converter.schemas.enable=false key.converter=org.apache.kafka.connect.storage.StringConverter