Package org.apache.calcite.adapter.kafka
Class KafkaTableOptions
java.lang.Object
org.apache.calcite.adapter.kafka.KafkaTableOptions
Available options for
KafkaStreamTable
.-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.kafka.clients.consumer.Consumer
setBootstrapServers
(String bootstrapServers) setConsumer
(org.apache.kafka.clients.consumer.Consumer consumer) setConsumerParams
(Map<String, String> consumerParams) setRowConverter
(KafkaRowConverter rowConverter) setTopicName
(String topicName)
-
Constructor Details
-
KafkaTableOptions
public KafkaTableOptions()
-
-
Method Details
-
getBootstrapServers
-
setBootstrapServers
-
getTopicName
-
setTopicName
-
getRowConverter
-
setRowConverter
-
getConsumerParams
-
setConsumerParams
-
getConsumer
public org.apache.kafka.clients.consumer.Consumer getConsumer() -
setConsumer
-