import Haskakafka import qualified Data.ByteString.Char8 as C8 example :: IO () example = do let -- Optionally, we can configure certain parameters for Kafka kafkaConfig = [("socket.timeout.ms", "50000")] topicConfig = [("request.timeout.ms", "50000")] -- Payloads are just ByteStrings samplePayload = C8.pack "Hello world" -- withKafkaProducer opens a producer connection and gives us -- two objects