shared-infrastructure/com.vertyll.veds.sharedinfrastructure.kafka/KafkaInfraProperties

KafkaInfraProperties

@ConfigurationProperties(prefix = "spring.kafka")

data class KafkaInfraProperties(val bootstrapServers: String = "localhost:29092", val schemaRegistryUrl: String = "http://localhost:8081", val consumer: KafkaInfraProperties.Consumer = Consumer())(source)

Type-safe configuration for the shared Kafka infrastructure.

Bound from spring.kafka.* in application.yml, mirroring the keys used by Spring Boot's own Kafka configuration so existing application-*.yml files remain compatible.

Replaces ad-hoc @Value("${spring.kafka.bootstrap-servers:...}") lookups and keeps the style consistent with MailProperties (mail-service) and SharedConfigProperties.

Constructors

KafkaInfraProperties

constructor(bootstrapServers: String = "localhost:29092", schemaRegistryUrl: String = "http://localhost:8081", consumer: KafkaInfraProperties.Consumer = Consumer())

Types

Consumer

data class Consumer(val groupId: String = "default-group", val autoOffsetReset: String = "earliest")

Properties

bootstrapServers

val bootstrapServers: String

Comma-separated list of Kafka broker addresses (host:port).

consumer

val consumer: KafkaInfraProperties.Consumer

schemaRegistryUrl

val schemaRegistryUrl: String

Schema Registry endpoint used by Avro serializer/deserializer.