Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5660

Don't throw TopologyBuilderException during runtime

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.11.0.0
    • 2.0.0
    • streams
    • None

    Description

      TopologyBuilderException is a pre-runtime exception that should only be thrown before KafkaStreams#start() is called.

      However, we do throw TopologyBuilderException within

      • `SourceNodeFactory#getTopics`
      • `ProcessorContextImpl#getStateStore`
      • `StreamPartitionAssignor#prepareTopic `

      (and maybe somewhere else: we should double check if there are other places in the code like those).

      We should replace those exception with either StreamsException or with a new exception type.

      Attachments

        Activity

          People

            nafshartous Nick Afshartous
            mjsax Matthias J. Sax
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: