com.databricks.sdk.service.pipelines

Class KafkaOptions

java.lang.Object

com.databricks.sdk.service.pipelines.KafkaOptions

@Generated
public class KafkaOptions
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaOptions()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Map<String,String>	getClientConfig()
Transformer	getKeyTransformer()
Long	getMaxOffsetsPerTrigger()
String	getStartingOffset()
String	getTopicPattern()
Collection<String>	getTopics()
Transformer	getValueTransformer()
int	hashCode()
KafkaOptions	setClientConfig(Map<String,String> clientConfig)
KafkaOptions	setKeyTransformer(Transformer keyTransformer)
KafkaOptions	setMaxOffsetsPerTrigger(Long maxOffsetsPerTrigger)
KafkaOptions	setStartingOffset(String startingOffset)
KafkaOptions	setTopicPattern(String topicPattern)
KafkaOptions	setTopics(Collection<String> topics)
KafkaOptions	setValueTransformer(Transformer valueTransformer)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaOptions

public KafkaOptions()

Method Detail

setClientConfig

public KafkaOptions setClientConfig(Map<String,String> clientConfig)

getClientConfig

public Map<String,String> getClientConfig()

setKeyTransformer

public KafkaOptions setKeyTransformer(Transformer keyTransformer)

getKeyTransformer

public Transformer getKeyTransformer()

setMaxOffsetsPerTrigger

public KafkaOptions setMaxOffsetsPerTrigger(Long maxOffsetsPerTrigger)

getMaxOffsetsPerTrigger

public Long getMaxOffsetsPerTrigger()

setStartingOffset

public KafkaOptions setStartingOffset(String startingOffset)

getStartingOffset

public String getStartingOffset()

setTopicPattern

public KafkaOptions setTopicPattern(String topicPattern)

getTopicPattern

public String getTopicPattern()

setTopics

public KafkaOptions setTopics(Collection<String> topics)

getTopics

public Collection<String> getTopics()

setValueTransformer

public KafkaOptions setValueTransformer(Transformer valueTransformer)

getValueTransformer

public Transformer getValueTransformer()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object