Add paused status to partition metadata
@@ -264,6 +264,7 @@ func (m *metadataAPI) createMetadataResponse(streams []string) *client.FetchMeta
Leader: leader,
Replicas: partition.GetReplicas(),
Isr: partition.GetISR(),
+ Paused: partition.GetPaused(),
}
}
metadata[i] = &client.StreamMetadata{
