public class StaticBrokerReader extends Object implements IBrokerReader
Constructor and Description |
---|
StaticBrokerReader(GlobalPartitionInformation partitionInformation) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
GlobalPartitionInformation |
getCurrentBrokers() |
public StaticBrokerReader(GlobalPartitionInformation partitionInformation)
public GlobalPartitionInformation getCurrentBrokers()
getCurrentBrokers
in interface IBrokerReader
public void close()
close
in interface IBrokerReader
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.