hw-kafka-client 2.3.3 → 2.4.0

raw patch · 3 files changed

+3/−3 lines, 3 files

Files

hw-kafka-client.cabal +1/−1
src/Kafka/Consumer.hs +1/−1
src/Kafka/Types.hs +1/−1

hw-kafka-client.cabal view

@@ -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

src/Kafka/Consumer.hs view

@@ -90,7 +90,7 @@             -> 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."

src/Kafka/Types.hs view

@@ -67,7 +67,7 @@   | KafkaResponseError RdKafkaRespErrT   | KafkaInvalidConfigurationValue String   | KafkaUnknownConfigurationKey String-  | KakfaBadConfiguration+  | KafkaBadConfiguration     deriving (Eq, Show, Typeable)  instance Exception KafkaError