Uploaded image for project: 'Nuxeo Platform'
  1. Nuxeo Platform
  2. NXP-27173

In StreamProcessor descriptor defaultPartitions is not taken in account

    XMLWordPrintable

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Minor
    • Resolution: Fixed
    • Affects Version/s: 9.10, 10.10
    • Fix Version/s: 10.10-HF19, 11.1, 2021.0
    • Component/s: Streams
    • Release Notes Summary:
      The default number of partitions is correctly set from the StreamProcessor configuration.
    • Team:
      PLATFORM
    • Sprint:
      nxplatform 11.1.23
    • Story Points:
      2

      Description

      When contributing a StreamProcessor the default number of partitions  for streams is not taken in account and is always 4.

      For instance in the below example the input stream will have 4 partitions instead of the 2 expected:

      <streamProcessor name="myStreamProcessor" class="..." defaultPartitions="2" logConfig="default">
       <computation name="myComputation" concurrency="1" />
        <stream name="input" codec="avro" /> 

      Note that specifying the number of partition at the Stream level do work as a workaround:

      <stream name="input" codec="avro" partitions="2" /> 

        Attachments

          Activity

            People

            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0 minutes
                0m
                Logged:
                Time Spent - 2 hours
                2h