Class TopicsConfig

  • All Implemented Interfaces:

    public class TopicsConfig
    extends java.lang.Object
    Contains the configuration for all Kafka topics that will be consumed by the Kafka source processor.
    See Also:
    Serialized Form
    • Constructor Detail

      • TopicsConfig

        public TopicsConfig()
    • Method Detail

      • addTopics

        public TopicsConfig addTopics​(java.util.List<java.lang.String> topicNames)
        Creates new topic configurations for every provided topic from the list and saves them in the map.
      • getInitialOffsetFor

        public java.lang.Long getInitialOffsetFor​(java.lang.String topicName,
                                                  int partition)
        Returns initial offset value for the given topic and partition combination. If configuration for specified topic does not exist, or if initial offset is not defined for the given partition then null is returned.
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object