Package fr.codinbox.connector.commons.kafka

Class KafkaConnectorServiceImpl

java.lang.Object

fr.codinbox.connector.commons.kafka.KafkaConnectorServiceImpl

All Implemented Interfaces:

KafkaConnectorService

public class KafkaConnectorServiceImpl
extends Object
implements KafkaConnectorService

Default implementation of KafkaConnectorService that discovers and manages Kafka connections from environment variables.

See Also:

• KafkaConnectorService
• KafkaConnectionImpl

Constructor Summary

Constructors

Constructor	Description
KafkaConnectorServiceImpl(@NotNull Logger logger)	Creates a new Kafka connector service.

Method Summary

Modifier and Type	Method	Description
@NotNull Optional<KafkaConnection>	getConnection(@NotNull String id)	Retrieves a Kafka connection by its identifier.
void	init()	Initializes all Kafka connections discovered from environment variables.
void	shutdown()	Shuts down all managed Kafka connections, gracefully closing all tracked clients.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KafkaConnectorServiceImpl

public KafkaConnectorServiceImpl(@NotNull
 @NotNull Logger logger)

Creates a new Kafka connector service.

Parameters:

logger - the logger for diagnostic messages

Method Details

init

public void init()
          throws ConnectionInitException

Description copied from interface: KafkaConnectorService

Initializes all Kafka connections discovered from environment variables.

Specified by:

init in interface KafkaConnectorService

Throws:

ConnectionInitException - if a connection with exit-on-failure enabled fails to initialize

shutdown

public void shutdown()

Description copied from interface: KafkaConnectorService

Shuts down all managed Kafka connections, gracefully closing all tracked clients.

Specified by:

shutdown in interface KafkaConnectorService

getConnection

@NotNull
public @NotNull Optional<KafkaConnection> getConnection(@NotNull
 @NotNull String id)

Description copied from interface: KafkaConnectorService

Retrieves a Kafka connection by its identifier.

Specified by:

getConnection in interface KafkaConnectorService

Parameters:

id - the connection identifier (case-sensitive, as extracted from environment variables)

Returns:

an Optional containing the connection, or empty if no connection exists with that id