org.apache.spark.streaming.kafka

Class KafkaCluster.SimpleConsumerConfig$

Object

org.apache.spark.streaming.kafka.KafkaCluster.SimpleConsumerConfig$

Enclosing class:

KafkaCluster

public static class KafkaCluster.SimpleConsumerConfig$
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static KafkaCluster.SimpleConsumerConfig$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
KafkaCluster.SimpleConsumerConfig$()

Method Summary

Methods

Modifier and Type	Method and Description
KafkaCluster.SimpleConsumerConfig	apply(scala.collection.immutable.Map<String,String> kafkaParams) Make a consumer config without requiring group.id or zookeeper.connect, since communicating with brokers also needs common settings such as timeout

Methods inherited from class Object

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

Field Detail

MODULE$

public static final KafkaCluster.SimpleConsumerConfig$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

KafkaCluster.SimpleConsumerConfig$

public KafkaCluster.SimpleConsumerConfig$()

Method Detail

apply

public KafkaCluster.SimpleConsumerConfig apply(scala.collection.immutable.Map<String,String> kafkaParams)

Make a consumer config without requiring group.id or zookeeper.connect, since communicating with brokers also needs common settings such as timeout

Parameters:

kafkaParams - (undocumented)

Returns:

(undocumented)