Class TopicPartition

    • Constructor Detail

      • TopicPartition

        public TopicPartition​(String topic,
                              int partition)
    • Method Detail

      • partition

        public int partition()
      • topic

        public String topic()
      • setTopic

        public void setTopic​(String topic)
        ONLY FOR MAPR INTERNAL USE! This method is used only for wrapping a user provided topic with a default stream. DO NOT USE DIRECTLY.
        Parameters:
        topic - new topic name
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object