oscerd commented on issue #1261: URL: https://github.com/apache/camel-kafka-connector/issues/1261#issuecomment-6632269116
Closing this as covered in 4.22.x without changing the core glue (the Kinesis-specific core change was declined in #1262, which suggested an SMT instead). Kinesis is now served by the Kamelet-based camel-aws-kinesis-sink-kafka-connector. Its Kamelet takes the partition key from a `partition` or `ce-partition` header and otherwise falls back to the exchange id, so records without headers are accepted. To use the Kafka record key as the partition key, copy it into a header with the bundled SMT: `transforms=keyToPartition`, `transforms.keyToPartition.type=org.apache.camel.kafkaconnector.transforms.FieldsToHeadersTransform$Key`, `transforms.keyToPartition.headers=CamelHeader.partition`. A null key still falls back to the exchange id (see https://camel.apache.org/camel-kafka-connector/next/reference/transformers/fieldsToHeaders.html). If this doesn't work for you on 4.22.x, please open a new issue with your version, configuration and stack trace. --- _Claude Code on behalf of Andrea Cosentino_ -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
