kamelets/kafka-to-kafka-with-manual-commit/flow-binding.yaml

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: kafka-to-log-with-manual-commit
spec:
  integration:
    configuration:
      - type: property
        value: "quarkus.log.level=DEBUG"
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-not-secured-source
    properties:
      brokers: 'my-cluster-kafka-bootstrap:9092'
      topic: 'test-topic-1'
      autoCommitEnable: false
      allowManualCommit: true
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-not-secured-sink
    properties:
      brokers: 'my-cluster-kafka-bootstrap:9092'
      topic: 'test-topic-2'
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: kafka-manual-commit-action
  sink:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: log-sink