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

Consumer

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

Constructors

constructor(groupId: String = "default-group", autoOffsetReset: String = "earliest")

Properties

autoOffsetReset

val autoOffsetReset: String

Where to start reading when no committed offset exists.

val groupId: String

Kafka consumer group id used by this service.