jbang/kafka-batch-azure-storage-blob/kafka-batch-azure-storage-blob.camel.yaml [22:39]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    from:
      uri: "kamelet:kafka-batch-not-secured-source"
      parameters:
        bootstrapServers: "localhost:9092"
        topic: "test-topic"
        consumerGroup: 'my-group'
        batchSize: 10
        pollTimeout: 40000
        maxPollIntervalMs: 60000
        autoCommitEnable: false
        allowManualCommit: true
        deserializeHeaders: true
      steps:
        - split:
            simple: "${body}"
            steps:
              - setHeader:
                  name: "file"
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



jbang/kafka-batch-s3/kafka-batch-s3.camel.yaml [22:39]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    from:
      uri: "kamelet:kafka-batch-not-secured-source"
      parameters:
        bootstrapServers: "localhost:9092"
        topic: "test-topic"
        consumerGroup: 'my-group'
        batchSize: 10
        pollTimeout: 40000
        maxPollIntervalMs: 60000
        autoCommitEnable: false
        allowManualCommit: true
        deserializeHeaders: true
      steps:
        - split:
            simple: "${body}"
            steps:
              - setHeader:
                  name: "file"
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



