Package fr.codinbox.connector.commons.kafka
package fr.codinbox.connector.commons.kafka
-
ClassDescriptionRepresents a managed Kafka connection that exposes the loaded configuration properties and provides factory methods for creating Kafka clients.Implementation of
KafkaConnectionthat loads Kafka properties from a file, provides factory methods for creating clients, and tracks them for graceful shutdown.Service interface for managing multiple named Kafka connections.Default implementation ofKafkaConnectorServicethat discovers and manages Kafka connections from environment variables.