flink-statefulfun-0.1.0.1: Flink stateful functions SDK
Safe HaskellNone
LanguageHaskell2010

Proto.Kafka

Synopsis

Documentation

data KafkaProducerRecord Source #

Fields :

  • key :: Lens' KafkaProducerRecord Data.Text.Text
  • valueBytes :: Lens' KafkaProducerRecord Data.ByteString.ByteString
  • topic :: Lens' KafkaProducerRecord Data.Text.Text

Instances

Instances details
Eq KafkaProducerRecord Source # 
Instance details

Defined in Proto.Kafka

Ord KafkaProducerRecord Source # 
Instance details

Defined in Proto.Kafka

Show KafkaProducerRecord Source # 
Instance details

Defined in Proto.Kafka

NFData KafkaProducerRecord Source # 
Instance details

Defined in Proto.Kafka

Methods

rnf :: KafkaProducerRecord -> () #

Message KafkaProducerRecord Source # 
Instance details

Defined in Proto.Kafka

HasField KafkaProducerRecord "key" Text Source # 
Instance details

Defined in Proto.Kafka

Methods

fieldOf :: Functor f => Proxy# "key" -> (Text -> f Text) -> KafkaProducerRecord -> f KafkaProducerRecord #

HasField KafkaProducerRecord "topic" Text Source # 
Instance details

Defined in Proto.Kafka

Methods

fieldOf :: Functor f => Proxy# "topic" -> (Text -> f Text) -> KafkaProducerRecord -> f KafkaProducerRecord #

HasField KafkaProducerRecord "valueBytes" ByteString Source # 
Instance details

Defined in Proto.Kafka

Methods

fieldOf :: Functor f => Proxy# "valueBytes" -> (ByteString -> f ByteString) -> KafkaProducerRecord -> f KafkaProducerRecord #