Package fr.codinbox.connector.commons.kafka


package fr.codinbox.connector.commons.kafka
  • Class
    Description
    Represents a managed Kafka connection that exposes the loaded configuration properties and provides factory methods for creating Kafka clients.
    Implementation of KafkaConnection that 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 of KafkaConnectorService that discovers and manages Kafka connections from environment variables.