[jira] [Created] (APEXMALHAR-1994) Operator partitions are reporting offsets for kafka partitions they don't subscribe to in kafka input operator

[Pramod Immaneni (JIRA)]

Pramod Immaneni created APEXMALHAR-1994:
-------------------------------------------

             Summary: Operator partitions are reporting offsets for kafka 
partitions they don't subscribe to in kafka input operator
                 Key: APEXMALHAR-1994
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-1994
             Project: Apache Apex Malhar
          Issue Type: Bug
            Reporter: Pramod Immaneni
            Assignee: Pramod Immaneni


Operator partitions are reporting offsets for kafka partitions beyond the 
partitions they individually subscribe to. Specifically they are reporting 
offsets for all partitions whose offsets are available in offset manager 
storage when the operator starts.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)