Package ai.pipestream.common.config

Class GlobalKafkaConsumerConfig

java.lang.Object

ai.pipestream.common.config.GlobalKafkaConsumerConfig

@ApplicationScoped
public class GlobalKafkaConsumerConfig
extends Object

Centralized Kafka Consumer Configuration.

Use this via: mp.messaging.incoming.[channel].kafka-configuration=pipestream-consumer

Enforces: 1. UUID Deserialization (Matches the Producer). 2. Protobuf Deserialization (Apicurio). 3. "Earliest" offset reset (Critical for the "Rewind" capability).

Constructor Summary

Constructors

Constructor	Description
GlobalKafkaConsumerConfig()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

GlobalKafkaConsumerConfig

public GlobalKafkaConsumerConfig()

Method Details

getConsumerConfig

@Produces
@Identifier("pipestream-consumer")
public Map<String,Object> getConsumerConfig()