kafka:
  server: pkc-412nj.europe-west1.gcp.confluent.cloud:9092
  enabled: true
  username: 6FZ6LCUOSZ6YR455
  password: 4yhbwYD9JrzMXg4Rl8z3RJZALcjPwddi1OaUvNHuiJsLj1SCCpRBncbti+vrKnx+
  group-id: testLocal05
  topic: events.masq.instance-qa
  output-topic: events.planning.instance-batch-local
  concurrency: 24 #recommended to be equal to nr of partitions of the Kafka topic
schema-registry:
  username: admin
  password: P4JUNKIzek3olJWSm70Y
server:
  port: 7777
spring:
  kafka:
    listener:
      ack-mode: batch
    producer:
      bootstrap-servers: ${kafka.server}
      key-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
      value-serializer: io.confluent.kafka.serializers.KafkaAvroSerializer
      properties:
        basic:
          auth:
            user:
              info: ${schema-registry.username}:${schema-registry.password}
            credentials:
              source: USER_INFO
        schema:
          registry:
            url: https://confluent-schema-registry-np.qone.mateco.eu
        sasl:
          mechanism: PLAIN
          jaas:
            config: org.apache.kafka.common.security.plain.PlainLoginModule required username="${kafka.username}" password="${kafka.password}";
        security:
          protocol: SASL_SSL
        ssl.endpoint.identification.algorithm: https
        request.timeout.ms: 20000
        retry.backoff.ms: 500
      transaction-id-prefix: ${random.uuid}
    consumer:
      bootstrap-servers: ${kafka.server}
      properties:
        basic:
          auth:
            user:
              info: ${schema-registry.username}:${schema-registry.password}
            credentials:
              source: USER_INFO
        schema:
          registry:
            url: https://confluent-schema-registry-np.qone.mateco.eu
        sasl:
          mechanism: PLAIN
          jaas:
            config: org.apache.kafka.common.security.plain.PlainLoginModule required username="${kafka.username}" password="${kafka.password}";
        security:
          protocol: SASL_SSL
      key-deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
      value-deserializer: io.confluent.kafka.serializers.KafkaAvroDeserializer
      auto-offset-reset: latest
      isolation-level: read_committed
      enable-auto-commit: true
      max-poll-records: 200