Kafka over the Apache clients, made suspending — typed publishers and a poll loop, serialized with kotlinx.serialization