Skip to content

viartemev/kafka-on-the-shore

Repository files navigation

Kafka on the Shore

Usage:

- Async message sending:
async { kafkaProducer.dispatch(ProducerRecord("topic", "This is record")) }
- Async consumer commit:
async { kafkaConsumer.commitAsync() }