Hi, You need to set the following option in your configuration: camel.source.camelMessageHeaderKey
The description "The name of a camel message header containing an unique key that can be used as a Kafka message key. If this is not specified, then the Kafka message will not have a key." For example you can use the file name, which it is stored in CamelAwsS3Key Camel header. Il giorno gio 11 feb 2021 alle ore 04:41 Arundhati Bhende < [email protected]> ha scritto: > Hello, > > When setting up the AWS S3 source connector, when we add a file to S3, > the entire file gets added to the topic as a message ( value ). What is > the key for this file, where is it defined or is there a way we can define > the key for such a connector? > > Thank you > Arundhati > >
