Class DefaultKafkaClientSupplier

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.kafka.clients.admin.AdminClient getAdminClient​(java.util.Map<java.lang.String,​java.lang.Object> config)
      Create an AdminClient which is used for internal topic management.
      org.apache.kafka.clients.consumer.Consumer<byte[],​byte[]> getConsumer​(java.util.Map<java.lang.String,​java.lang.Object> config)
      Create a Consumer which is used to read records of source topics.
      org.apache.kafka.clients.consumer.Consumer<byte[],​byte[]> getGlobalConsumer​(java.util.Map<java.lang.String,​java.lang.Object> config)
      Create a Consumer which is used to consume records for GlobalKTable.
      org.apache.kafka.clients.producer.Producer<byte[],​byte[]> getProducer​(java.util.Map<java.lang.String,​java.lang.Object> config)
      Create a Producer which is used to write records to sink topics.
      org.apache.kafka.clients.consumer.Consumer<byte[],​byte[]> getRestoreConsumer​(java.util.Map<java.lang.String,​java.lang.Object> config)
      Create a Consumer which is used to read records to restore StateStores.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • DefaultKafkaClientSupplier

        public DefaultKafkaClientSupplier()
    • Method Detail

      • getAdminClient

        public org.apache.kafka.clients.admin.AdminClient getAdminClient​(java.util.Map<java.lang.String,​java.lang.Object> config)
        Description copied from interface: KafkaClientSupplier
        Create an AdminClient which is used for internal topic management.
        Specified by:
        getAdminClient in interface KafkaClientSupplier
        Parameters:
        config - Supplied by the Properties given to the KafkaStreams
        Returns:
        an instance of AdminClient
      • getProducer

        public org.apache.kafka.clients.producer.Producer<byte[],​byte[]> getProducer​(java.util.Map<java.lang.String,​java.lang.Object> config)
        Description copied from interface: KafkaClientSupplier
        Create a Producer which is used to write records to sink topics.
        Specified by:
        getProducer in interface KafkaClientSupplier
        Parameters:
        config - producer config which is supplied by the Properties given to the KafkaStreams instance
        Returns:
        an instance of Kafka producer
      • getConsumer

        public org.apache.kafka.clients.consumer.Consumer<byte[],​byte[]> getConsumer​(java.util.Map<java.lang.String,​java.lang.Object> config)
        Description copied from interface: KafkaClientSupplier
        Create a Consumer which is used to read records of source topics.
        Specified by:
        getConsumer in interface KafkaClientSupplier
        Parameters:
        config - consumer config which is supplied by the Properties given to the KafkaStreams instance
        Returns:
        an instance of Kafka consumer
      • getRestoreConsumer

        public org.apache.kafka.clients.consumer.Consumer<byte[],​byte[]> getRestoreConsumer​(java.util.Map<java.lang.String,​java.lang.Object> config)
        Description copied from interface: KafkaClientSupplier
        Create a Consumer which is used to read records to restore StateStores.
        Specified by:
        getRestoreConsumer in interface KafkaClientSupplier
        Parameters:
        config - restore consumer config which is supplied by the Properties given to the KafkaStreams
        Returns:
        an instance of Kafka consumer
      • getGlobalConsumer

        public org.apache.kafka.clients.consumer.Consumer<byte[],​byte[]> getGlobalConsumer​(java.util.Map<java.lang.String,​java.lang.Object> config)
        Description copied from interface: KafkaClientSupplier
        Create a Consumer which is used to consume records for GlobalKTable.
        Specified by:
        getGlobalConsumer in interface KafkaClientSupplier
        Parameters:
        config - global consumer config which is supplied by the Properties given to the KafkaStreams
        Returns:
        an instance of Kafka consumer