diff --git a/hw-kafka-client.cabal b/hw-kafka-client.cabal
--- a/hw-kafka-client.cabal
+++ b/hw-kafka-client.cabal
@@ -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
diff --git a/src/Kafka/Metadata.hs b/src/Kafka/Metadata.hs
--- a/src/Kafka/Metadata.hs
+++ b/src/Kafka/Metadata.hs
@@ -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
     }
 
 
diff --git a/tests-it/Kafka/TestEnv.hs b/tests-it/Kafka/TestEnv.hs
--- a/tests-it/Kafka/TestEnv.hs
+++ b/tests-it/Kafka/TestEnv.hs
@@ -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