Package-level declarations
Types
Link copied to clipboard
class KafkaListener<Key, Value>(topicNames: List<String>, properties: KafkaListenerProperties<Key, Value>, pollDuration: Duration = Duration.ofMillis(100), processor: suspend (ConsumerRecord<Key, Value>) -> Unit) : AutoCloseable
Link copied to clipboard
data class KafkaListenerProperties<Key, Value>(val bootstrapServers: String, val keyDeserializer: Deserializer<Key>, val valueDeserializer: Deserializer<Value>, val groupId: String, val autoCommit: Boolean = false, val autoOffsetResetStrategy: OffsetResetStrategy = OffsetResetStrategy.EARLIEST, val properties: Properties = Properties())
Link copied to clipboard
data class KafkaProducerProperties<Key, Value>(val bootstrapServers: String, val keySerializer: Serializer<Key>, val valueSerializer: Serializer<Value>, val properties: Properties = Properties())
Functions
Link copied to clipboard
fun <Key, Value> KafkaProducer(properties: KafkaProducerProperties<Key, Value>): KafkaProducer<Key, Value>
Link copied to clipboard