Crate malstrom_kafka 

Structs

KafkaRecord

A single record as received by or sent to Kafka

KafkaSink

KafkaSource

Create a new KafkaSource for a given topic. This is a partitioned source with each Kafka partition mapping to one StatefulSourcePartition. NOTE: Records with an empty payload are not emitted to the stream.

KafkaSourcePartition

A single partition of KafkaSource. This type can not be constructed directly, use KafkaSource instead.