[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286771#comment-17286771
]
Matthias J. Sax commented on KAFKA-12328:
-
Personally, I am open to expose the partition number
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286559#comment-17286559
]
fml2 commented on KAFKA-12328:
--
OK, the taskId is sufficient in my case as all I needed was to distinguish
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286175#comment-17286175
]
Matthias J. Sax commented on KAFKA-12328:
-
Yes, the state store changelog topic has one
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286159#comment-17286159
]
fml2 commented on KAFKA-12328:
--
OK, I did not know that a task is created per partition, i.e. that there is
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286047#comment-17286047
]
Matthias J. Sax commented on KAFKA-12328:
-
It's correct that a task may process multiple
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285814#comment-17285814
]
fml2 commented on KAFKA-12328:
--
Hrm... IIUC a task can process multiple partitions (e.g. a join task),
[
https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17285569#comment-17285569
]
Matthias J. Sax commented on KAFKA-12328:
-
You should be able to use `ProcessorContext.taskId()`
