From 33bd3ffe154661fca3cbf7d5e905c17aa4029126 Mon Sep 17 00:00:00 2001 From: alexeyraga Date: Thu, 15 Mar 2018 19:30:17 +1100 Subject: [PATCH 1/2] no event poll on message --- src/Kafka/Consumer.hs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Kafka/Consumer.hs b/src/Kafka/Consumer.hs index bedfe00..5e2cee2 100644 --- a/src/Kafka/Consumer.hs +++ b/src/Kafka/Consumer.hs @@ -90,7 +90,7 @@ pollMessage :: MonadIO m -> Timeout -- ^ the timeout, in milliseconds -> m (Either KafkaError (ConsumerRecord (Maybe BS.ByteString) (Maybe BS.ByteString))) -- ^ Left on error or timeout, right for success pollMessage c@(KafkaConsumer _ (KafkaConf _ qr _)) (Timeout ms) = liftIO $ do - pollConsumerEvents c Nothing +-- pollConsumerEvents c Nothing mbq <- readIORef qr case mbq of Nothing -> return . Left $ KafkaBadSpecification "Messages queue is not configured, internal error, fatal." From 956e8329b2528dc4791cc8c5931367939d7cbfa7 Mon Sep 17 00:00:00 2001 From: alexeyraga Date: Thu, 15 Mar 2018 22:10:30 +1100 Subject: [PATCH 2/2] Bump version --- hw-kafka-client.cabal | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hw-kafka-client.cabal b/hw-kafka-client.cabal index 3ea993f..fbfb085 100644 --- a/hw-kafka-client.cabal +++ b/hw-kafka-client.cabal @@ -1,5 +1,5 @@ name: hw-kafka-client -version: 2.3.3 +version: 2.4.0 homepage: https://github.com/haskell-works/hw-kafka-client bug-reports: https://github.com/haskell-works/hw-kafka-client/issues license: MIT