Package org.apache.calcite.adapter.kafka

Class KafkaTableOptions

java.lang.Object

org.apache.calcite.adapter.kafka.KafkaTableOptions

public final class KafkaTableOptions
extends Object

Available options for KafkaStreamTable.

Constructor Summary

Constructors

Constructor	Description
KafkaTableOptions()

Method Summary

Modifier and Type	Method	Description
String	getBootstrapServers()
org.apache.kafka.clients.consumer.Consumer	getConsumer()
Map<String,String>	getConsumerParams()
KafkaRowConverter	getRowConverter()
String	getTopicName()
KafkaTableOptions	setBootstrapServers(String bootstrapServers)
KafkaTableOptions	setConsumer(org.apache.kafka.clients.consumer.Consumer consumer)
KafkaTableOptions	setConsumerParams(Map<String,String> consumerParams)
KafkaTableOptions	setRowConverter(KafkaRowConverter rowConverter)
KafkaTableOptions	setTopicName(String topicName)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaTableOptions

public KafkaTableOptions()

Method Details

getBootstrapServers

public String getBootstrapServers()

setBootstrapServers

public KafkaTableOptions setBootstrapServers(String bootstrapServers)

getTopicName

public String getTopicName()

setTopicName

public KafkaTableOptions setTopicName(String topicName)

getRowConverter

public KafkaRowConverter getRowConverter()

setRowConverter

public KafkaTableOptions setRowConverter(KafkaRowConverter rowConverter)

getConsumerParams

public Map<String,String> getConsumerParams()

setConsumerParams

public KafkaTableOptions setConsumerParams(Map<String,String> consumerParams)

getConsumer

public org.apache.kafka.clients.consumer.Consumer getConsumer()

setConsumer

public KafkaTableOptions setConsumer(org.apache.kafka.clients.consumer.Consumer consumer)