| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Network.Flink.Kafka
Description
Kafka specific functions
Synopsis
- kafkaRecord :: Message v => Text -> Text -> v -> KafkaProducerRecord
Documentation
Arguments
| :: Message v | |
| => Text | Kafka topic |
| -> Text | Kafka key |
| -> v | Kafka value |
| -> KafkaProducerRecord |
Takes a topic, key, and protobuf value to construct KafkaProducerRecords for egress