public class ConfigHelper extends Object
Class containing helper methods to retrieve the default configuration for Zookeeper and Kafka consumers & producers
| Constructor and Description |
|---|
ConfigHelper() |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.kafka.clients.consumer.Consumer<TaskState,TaskConfiguration> |
kafkaConsumer(String groupId,
Properties properties) |
static org.apache.kafka.clients.producer.Producer<TaskState,TaskConfiguration> |
kafkaProducer(Properties properties) |
public static org.apache.kafka.clients.consumer.Consumer<TaskState,TaskConfiguration> kafkaConsumer(String groupId, Properties properties)
public static org.apache.kafka.clients.producer.Producer<TaskState,TaskConfiguration> kafkaProducer(Properties properties)
Copyright © 2017 Grakn Labs Ltd. All rights reserved.