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