topical Topic-oriented API for producing and consuming Kafka streams with support for pluggable codecs