}
@Override
public Consumer createConsumer(Collection<String> pool, String readTopic,
String clientName, String clientId, String filterJson, String apiKey, String apiSecret) {
}
@Override
public Consumer createConsumer(Collection<String> pool, String readTopic,
String clientName, String clientId, String filterJson, String apiKey, String apiSecret) {