kafka:
  # Kafka broker configuration
  bootstrap:
    servers: localhost:9092

  # Producer configuration (for exactly-once semantics)
  enable:
    idempotence: true
  acks: all
  # Schema Registry configuration
  schema:
    registry:
      url: http://localhost:8081

mp:
  messaging:
    # Confluent Schema Registry configuration
    connector:
      smallrye-kafka:
        schema:
          registry:
            url: http://localhost:8081

    # Consumer configuration for your CDC topic
    incoming:
      readSegmentsAssociationValueEvent:
        connector: smallrye-kafka
        topic: nextgen_dev_000_segmentsassociation_raw_v1
        group:
          id: segments-association-consumer-group
        # Ignore deserialization failures
        fail-on-deserialization-failure: true
        # Confluent AVRO deserializers
        key:
          deserializer: org.apache.kafka.common.serialization.StringDeserializer
        value:
          deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
        # Confluent Schema Registry specific settings
        schema:
          registry:
            url: http://localhost:8081
        specific:
          avro:
            reader: true
        # Auto offset reset
        auto:
          offset:
            reset: earliest
          commit:
            interval:
              ms: 5000
        # Consumer performance tuning for CDC workloads
        max:
          poll:
            records: 100
        enable:
          auto:
            commit: true
        # Isolation level for exactly-once processing
        isolation:
          level: read_committed
        # Error handling - retry configuration
        failure-strategy: ignore
        batch: false
        # Disable both liveness and readiness checks with `health-enabled=false`:
#        health-enabled: false
        health-readiness-enabled: true