Configuration

Objetivo

El objetivo de esta librería es abstraer al desarrollador de la implementación de Apache Kafka y brindarle herramientas para que, rápidamente, pueda integrar AMQStream en sus proyectos.

La actual librería utiliza las librerías de Confluent kafka como base para poder interactuar con Apache Kafka. ver confluent-kafka

Configuración

Configuración inicial

ApplicationName: Example
AMQStreams:  
  BootstrapServer: "localhost:9092"  
  SchemaUrl: "http://localhost:8081/api/ccompat" 

name	descripción
ApplicationName	Valor que se utiliza para definir el remitente y el consumer group
BootstrapServer	URL de acceso al broker de kafka
SchemaUrl	URL de acceso a apicurio registry

Configuración avanzada

ApplicationName: Example
AMQStreams:
  GroupId: ExampleGroup
  BootstrapServer: "SSL://cluster-prod-kafka-bootstrap-amq-streams.apps.ocpprod.andreani.com.ar:443"
  SchemaUrl: "http://apicurioregistry.apps.ocpprod.andreani.com.ar/apis/ccompat/v6"
  Protocol: Ssl
  SslCertificateLocation: "./kafka.pem"
  EnableSslCertificateVerification: false
  AutoOffsetReset: Earliest
  AutoRegisterSchemas: true

name	descripción
GroupId	representa el valor de consumer group. Default: ApplicationName
Protocol	Protocolo de conexión al broker opciones: Ssl, Plaintext Default: Plaintext
SslCertificateLocation	Path de ubicación de certificado SSL. Default: ""
EnableSslCertificateVerification	La aplicación puede ampliar esta verificación mediante la implementación de un certificate_verify_cb. Default: false
AutoOffsetReset	Permite establecer la estrategia de offset inicial para la lectura de los Consumers. Opciones Latest, Earliest, Error. Default: Earliest
AutoRegisterSchemas	Si está seteado en true, permite registrar, en caso que no existan, el schema en apicurio registry. Default: false

Para más información de la configuración de kafka, consumers o producers ver -> KafkaConfig, ConsumerConfig, ProducerConfig