hw-kafka-client 2.0.0 → 2.0.1

raw patch · 3 files changed

+6/−8 lines, 3 filesnew-uploader

Files

• hw-kafka-client.cabal +1/−1
• src/Kafka/Metadata.hs +4/−4
• tests-it/Kafka/TestEnv.hs +1/−3

@@ -1,5 +1,5 @@ name:                hw-kafka-client-version:             2.0.0+version:             2.0.1 homepage:            https://github.com/haskell-works/hw-kafka-client bug-reports:         https://github.com/haskell-works/hw-kafka-client/issues license:             MIT

@@ -43,8 +43,8 @@   { pmPartitionId    :: !PartitionId   , pmError          :: Maybe KafkaError   , pmLeader         :: !BrokerId-  , pmReplicas       :: [PartitionId]-  , pmInSyncReplicas :: [PartitionId]+  , pmReplicas       :: [BrokerId]+  , pmInSyncReplicas :: [BrokerId]   } deriving (Show, Eq)  data TopicMetadata = TopicMetadata@@ -250,8 +250,8 @@     { pmPartitionId     = PartitionId (id'RdKafkaMetadataPartitionT pm)     , pmError           = kafkaErrorToMaybe $ KafkaResponseError (err'RdKafkaMetadataPartitionT pm)     , pmLeader          = BrokerId (leader'RdKafkaMetadataPartitionT pm)-    , pmReplicas        = (PartitionId . fromIntegral) <$> reps-    , pmInSyncReplicas  = (PartitionId . fromIntegral) <$> isrs+    , pmReplicas        = (BrokerId . fromIntegral) <$> reps+    , pmInSyncReplicas  = (BrokerId . fromIntegral) <$> isrs     }  

@@ -1,8 +1,7 @@ {-# LANGUAGE OverloadedStrings   #-} {-# LANGUAGE ScopedTypeVariables #-} -module Kafka.TestEnv-where+module Kafka.TestEnv where  import Control.Exception import Control.Monad      (void)@@ -11,7 +10,6 @@ import System.IO.Unsafe  import Kafka.Consumer as C-import Kafka.Metadata as M import Kafka.Producer as P  import Test.Hspec