Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-2590 KIP-28: Kafka Streams Checklist
  3. KAFKA-2707

Make KStream processor names deterministic

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.10.0.0
    • Component/s: None
    • Labels:
      None

      Description

      Currently KStream processor names are generated from AtomicInteger static member of KStreamImpl. It is incremented every time a new processor is created. The problem is the name depends on the usage history of its use in the same JVM, thus the corresponding processors may have different names in different processes. It makes it difficult to debug.

        Attachments

          Activity

            People

            • Assignee:
              yasuhiro.matsuda Yasuhiro Matsuda
              Reporter:
              yasuhiro.matsuda Yasuhiro Matsuda
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: