Class KafkaTableOptions


  • public final class KafkaTableOptions
    extends java.lang.Object
    Available options for KafkaStreamTable.
    • Field Detail

      • bootstrapServers

        private java.lang.String bootstrapServers
      • topicName

        private java.lang.String topicName
      • consumerParams

        private java.util.Map<java.lang.String,​java.lang.String> consumerParams
      • consumer

        private org.apache.kafka.clients.consumer.Consumer consumer
    • Constructor Detail

      • KafkaTableOptions

        public KafkaTableOptions()
    • Method Detail

      • getBootstrapServers

        public java.lang.String getBootstrapServers()
      • setBootstrapServers

        public KafkaTableOptions setBootstrapServers​(java.lang.String bootstrapServers)
      • getTopicName

        public java.lang.String getTopicName()
      • setTopicName

        public KafkaTableOptions setTopicName​(java.lang.String topicName)
      • getConsumerParams

        public java.util.Map<java.lang.String,​java.lang.String> getConsumerParams()
      • setConsumerParams

        public KafkaTableOptions setConsumerParams​(java.util.Map<java.lang.String,​java.lang.String> consumerParams)
      • getConsumer

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

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