Package ai.pipestream.common.config

Class GlobalKafkaConfig

java.lang.Object

ai.pipestream.common.config.GlobalKafkaConfig

@ApplicationScoped
public class GlobalKafkaConfig
extends Object

Centralized Kafka Producer Configuration.

This bean provides the standard configuration for all Pipestream microservices. It enforces: 1. RAW UUID Keys (16 bytes) for efficiency and strict typing. 2. Apicurio/Protobuf serialization for values. 3. Idempotency and high-reliability settings. 4. HIGH THROUGHPUT batching for pipeline performance.

Constructor Summary

Constructors

Constructor	Description
GlobalKafkaConfig()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	getProducerConfig()

Methods inherited from class java.lang.Object

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

Constructor Details

GlobalKafkaConfig

public GlobalKafkaConfig()

Method Details

getProducerConfig

@Produces
@Identifier("pipestream-producer")
public Map<String,Object> getProducerConfig()