[GitHub] [camel-kafka-connector] gohanbg removed a comment on issue #1300: CamelAws2s3SinkConnector not processing kafka null (deleted) messages

[GitBox <gi...@apache.org>]

gohanbg removed a comment on issue #1300:
URL: https://github.com/apache/camel-kafka-connector/issues/1300#issuecomment-997408748


   I tried with the simple string converter instead of Avro converter
   
   ```
   apiVersion: kafka.strimzi.io/v1beta2
   kind: KafkaConnector
   metadata:
     name: s3-sink-connector21
     labels:
       strimzi.io/cluster: aws-connect
   spec:
     class: org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SinkConnector
     tasksMax: 1
     config:
       key.converter: org.apache.kafka.connect.storage.StringConverter
       value.converter: org.apache.kafka.connect.storage.StringConverter
       #value.converter: io.confluent.connect.avro.AvroConverter
       #value.converter.schema.registry.url: http://confluent-cp-schema-registry.messaging.svc:8081
       topics: advertisements
       camel.sink.path.bucketNameOrArn: cc-kafka-test-bucket
       camel.sink.endpoint.keyName: ${date:now:yyyyMMdd-HHmmssSSS}-${exchangeId}
       camel.sink.maxPollDuration: 10000
       transforms: tojson
       transforms.tojson.type: org.apache.camel.kafkaconnector.aws2s3.transformers.RecordToJSONTransforms
       camel.component.aws2-s3.accessKey: ${file:/opt/kafka/external-configuration/kafka-aws-credentials/kafka-s3-credentials.properties:aws_access_key_id}
       camel.component.aws2-s3.secretKey: ${file:/opt/kafka/external-configuration/kafka-aws-credentials/kafka-s3-credentials.properties:aws_secret_access_key}
       camel.component.aws2-s3.region: eu-central-1
   
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@camel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org