Haskakafka.InternalSetup

Documentation

newKafka :: RdKafkaTypeT -> ConfigOverrides -> IO Kafka

Create kafka object with the given configuration. Most of the time you will not need to use this function directly (see withKafkaProducer and withKafkaConsumer).

newKafkaTopic :: Kafka -> String -> ConfigOverrides -> IO KafkaTopic

Create a kafka topic object with the given configuration. Most of the time you will not need to use this function directly (see withKafkaProducer and withKafkaConsumer)

newKafkaPtr :: RdKafkaTypeT -> KafkaConf -> IO Kafka

newKafkaTopicPtr :: Kafka -> String -> KafkaTopicConf -> IO KafkaTopic

setLogLevel :: Kafka -> KafkaLogLevel -> IO ()

Sets library log level (noisiness) with respect to a kafka instance

type ConfigOverrides = [(String, String)]

Used to override default config properties for consumers and producers

newKafkaTopicConf :: IO KafkaTopicConf

newKafkaConf :: IO KafkaConf

kafkaConf :: ConfigOverrides -> IO KafkaConf

kafkaTopicConf :: ConfigOverrides -> IO KafkaTopicConf

checkConfSetValue :: RdKafkaConfResT -> CCharBufPointer -> IO ()

setKafkaConfValue :: KafkaConf -> String -> String -> IO ()

setAllKafkaConfValues :: KafkaConf -> ConfigOverrides -> IO ()

setKafkaTopicConfValue :: KafkaTopicConf -> String -> String -> IO ()

setAllKafkaTopicConfValues :: KafkaTopicConf -> ConfigOverrides -> IO ()

hPrintSupportedKafkaConf :: Handle -> IO ()

Prints out all supported Kafka conf properties to a handle

hPrintKafka :: Handle -> Kafka -> IO ()

Prints out all data associated with a specific kafka object to a handle

dumpConfFromKafka :: Kafka -> IO (Map String String)

Returns a map of the current kafka configuration

dumpConfFromKafkaTopic :: KafkaTopic -> IO (Map String String)

Returns a map of the current topic configuration

dumpKafkaTopicConf :: KafkaTopicConf -> IO (Map String String)

dumpKafkaConf :: KafkaConf -> IO (Map String String)

parseDump :: (CSizePtr -> IO (Ptr CString)) -> IO (Map String String)

listToTuple :: [String] -> [(String, String)]