This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch kafka-batch-s3 in repository https://gitbox.apache.org/repos/asf/camel-kamelets-examples.git
commit 35ca1719cc9a28a927e6b07ac872615bb5e73a28 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Feb 16 12:03:04 2024 +0100 Modified the example of Kafka Batch to s3 a little Signed-off-by: Andrea Cosentino <[email protected]> --- jbang/kafka-batch-s3/kafka-batch-log.yaml | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/jbang/kafka-batch-s3/kafka-batch-log.yaml b/jbang/kafka-batch-s3/kafka-batch-log.yaml index a1e4e6d..8db16e4 100644 --- a/jbang/kafka-batch-s3/kafka-batch-log.yaml +++ b/jbang/kafka-batch-s3/kafka-batch-log.yaml @@ -35,13 +35,9 @@ - split: simple: "${body}" steps: - - setHeaders: - headers: - - name: "kafka.TOPIC" - simple: "${body.getMessage().getHeader('kafka.TOPIC')}" - setHeader: name: "file" - simple: "${headers[kafka.TOPIC]}-${date:now:yyyyMMddHHmmssSSS}.txt" + simple: "${body.getMessage().getHeader('kafka.TOPIC')}-${date:now:yyyyMMddHHmmssSSS}.txt" - setBody: simple: "${body.getMessage().getBody()}" - to:
