Class AutoCreateTopicsInterceptor

    • Constructor Detail

      • AutoCreateTopicsInterceptor

        public AutoCreateTopicsInterceptor​(org.apache.kafka.clients.admin.AdminClient adminClient)
        Creates a new AutoCreateTopicsInterceptor instance.
        Parameters:
        adminClient - the AdminClient to be used.
    • Method Detail

      • setReplicationFactor

        public void setReplicationFactor​(short replicationFactor)
        Sets the default replication factor uses for creating topics.
        Parameters:
        replicationFactor - the replication factor.
      • setNumPartitions

        public void setNumPartitions​(int numPartitions)
        Sets the default number of partitions uses for creating topics.
        Parameters:
        numPartitions - the number of partitions.
      • setTopics

        public void setTopics​(Collection<org.apache.kafka.clients.admin.NewTopic> topics)
        Sets the list of new topics to create.
        Parameters:
        topics - the list of NewTopic instances.
      • setTopicConfigs

        public void setTopicConfigs​(Map<String,​String> topicConfigs)
      • setDeleteTopicsOnStreamsClosed

        public void setDeleteTopicsOnStreamsClosed​(boolean delete)
        Sets if topics should be automatically deleted once the streams is closed.
        Parameters:
        delete - true to enable, otherwise false.