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

Add Support to Scala API for KIP-307 and KIP-479

    XMLWordPrintableJSON

Details

    • Task
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.4.0
    • 2.8.0
    • streams
    • None

    Description

      With the ability to provide names for all operators in a Kafka Streams topology (https://cwiki.apache.org/confluence/display/KAFKA/KIP-307%3A+Allow+to+define+custom+processor+names+with+KStreams+DSL) coming in the 2.4 release, we also need to add this new feature to the Streams Scala API.

      KIP-307 was refined via KIP-479 (https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3A+Add+StreamJoined+config+object+to+Join) and this ticket should cover both cases.

      Attachments

        Issue Links

          duplicates

          Improvement - An improvement or enhancement to an existing feature or task. KAFKA-12337 provide full scala api for operators naming

          • Major - Major loss of function.
          • Resolved
          links to

          Web Link GitHub Pull Request #9738

          Activity

            People

              mathieude Mathieu DESPRIEE
              bbejeck Bill Bejeck
              Votes:
              3 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: