Package app.l2nx.gs.adapter.core.kafka

Class KafkaInitializer

java.lang.Object

app.l2nx.gs.adapter.core.kafka.KafkaInitializer

public final class KafkaInitializer
extends Object

Bootstraps the nx-gs-kafka singleton from a platform-issued KafkaConfig. The state listener forwarded to the factory drives the adapter's ACTIVE ↔ DEGRADED transitions once the platform handshake has completed.

The JAAS line is hard-coded against org.apache.kafka.common.security.scram.ScramLoginModule — the only SASL mechanism the platform issues in the MVP.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SCRAM_LOGIN_MODULE

Constructor Summary

Constructors

Constructor	Description
KafkaInitializer(KafkaFactory factory)
KafkaInitializer(KafkaFactory factory, Map<String,Object> producerOverrides)

Method Summary

Modifier and Type	Method	Description
static String	buildJaas(String username, String password)
app.l2nx.gs.kafka.KafkaState	init(app.l2nx.gs.adapter.api.rest.KafkaConfig kafka, String clientId, Map<String,byte[]> staticHeaders, Consumer<app.l2nx.gs.kafka.KafkaState> stateChangeListener)	Build the Kafka client and return the post-build state.

Methods inherited from class java.lang.Object

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

Field Details

SCRAM_LOGIN_MODULE

public static final String SCRAM_LOGIN_MODULE

See Also:

• Constant Field Values

Constructor Details

KafkaInitializer

public KafkaInitializer(KafkaFactory factory)

KafkaInitializer

public KafkaInitializer(KafkaFactory factory,
 Map<String,Object> producerOverrides)

Method Details

init

public app.l2nx.gs.kafka.KafkaState init(app.l2nx.gs.adapter.api.rest.KafkaConfig kafka,
 String clientId,
 Map<String,byte[]> staticHeaders,
 Consumer<app.l2nx.gs.kafka.KafkaState> stateChangeListener)

Build the Kafka client and return the post-build state. Returns KafkaState.DISCONNECTED when the broker is unreachable inside the connect timeout — the adapter should reflect this as DEGRADED; nx-gs-kafka reconnects in the background.

Parameters:

kafka - wire payload from the platform handshake

clientId - composed client identifier (nx-gs-adapter-<tenant>-<server>)

staticHeaders - Kafka headers stamped on every produced record (e.g. Nx-Server-Id); may be empty

stateChangeListener - forwarded to NxKafka.onStateChange

buildJaas

public static String buildJaas(String username,
 String password)