net.bluemind.kafka.configuration

Class LocalConsumer

java.lang.Object

net.bluemind.kafka.configuration.LocalConsumer

public class LocalConsumer
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
LocalConsumer()

Method Summary

Modifier and Type	Method and Description
static org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String>	create(java.lang.String bootstapServer, java.lang.String gid, java.lang.String cid)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LocalConsumer

public LocalConsumer()

Method Detail

create

public static org.apache.kafka.clients.consumer.KafkaConsumer<java.lang.String,java.lang.String> create(java.lang.String bootstapServer,
                                                                                                        java.lang.String gid,
                                                                                                        java.lang.String cid)