[jira] [Commented] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287774#comment-17287774 ] fml2 commented on KAFKA-12328: -- I now see that a processor / transformer is inherently "not

[jira] [Updated] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-12328: - Description: This question was posted [on stackoverflow|https://stackoverflow.com/questions/66032099/kafka-stre

[jira] [Commented] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287625#comment-17287625 ] fml2 commented on KAFKA-12328: -- Just to let you know: After I changed the supplier implemen

[jira] [Comment Edited] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287386#comment-17287386 ] fml2 edited comment on KAFKA-12328 at 2/19/21, 9:53 PM: {quote}I

[jira] [Commented] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287386#comment-17287386 ] fml2 commented on KAFKA-12328: -- {quote}In general, the ideas of the "supplier pattern" is _

[jira] [Comment Edited] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287372#comment-17287372 ] fml2 edited comment on KAFKA-12328 at 2/19/21, 9:50 PM: {quote}i

[jira] [Commented] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287372#comment-17287372 ] fml2 commented on KAFKA-12328: -- {quote}ie, the supplier must return a new object each time

[jira] [Comment Edited] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287103#comment-17287103 ] fml2 edited comment on KAFKA-12328 at 2/19/21, 5:42 PM: Hrm... I

[jira] [Commented] (KAFKA-12328) Expose TaskId partition number

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17287103#comment-17287103 ] fml2 commented on KAFKA-12328: -- Hrm... It's weird, but: My setup is: I have three partitio

[jira] [Commented] (KAFKA-12328) Find out partition of a store iterator

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17286559#comment-17286559 ] fml2 commented on KAFKA-12328: -- OK, the taskId is sufficient in my case as all I needed was

[jira] [Commented] (KAFKA-12328) Find out partition of a store iterator

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17286159#comment-17286159 ] fml2 commented on KAFKA-12328: -- OK, I did not know that a task is created per partition, i.

[jira] [Commented] (KAFKA-12328) Find out partition of a store iterator

[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17285814#comment-17285814 ] fml2 commented on KAFKA-12328: -- Hrm... IIUC a task can process multiple partitions (e.g. a

[jira] [Created] (KAFKA-12328) Find out partition of a store iterator

fml2 created KAFKA-12328: Summary: Find out partition of a store iterator Key: KAFKA-12328 URL: https://issues.apache.org/jira/browse/KAFKA-12328 Project: Kafka Issue Type: Wish Reporter:

[jira] [Commented] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234030#comment-17234030 ] fml2 commented on KAFKA-10722: -- I've created [https://github.com/apache/kafka/pull/9606] an

[jira] [Commented] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233730#comment-17233730 ] fml2 commented on KAFKA-10722: -- {quote}If you would add a new store (that is not used by –

[jira] [Commented] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233116#comment-17233116 ] fml2 commented on KAFKA-10722: -- OK, I accept that Kafka Streams needs timestamps for the in

[jira] [Commented] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231981#comment-17231981 ] fml2 commented on KAFKA-10722: -- Matthias, does your response mean that we *always* get a ti

[jira] [Comment Edited] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231972#comment-17231972 ] fml2 edited comment on KAFKA-10722 at 11/14/20, 10:29 AM: -- Hell

[jira] [Commented] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231972#comment-17231972 ] fml2 commented on KAFKA-10722: -- Hello, thank you for the quick response! This perfectly mak

[jira] [Updated] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-10722: - Description: I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I e

[jira] [Updated] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-10722: - Description: I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I e

[jira] [Updated] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-10722: - Description: I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I e

[jira] [Updated] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-10722: - Description: I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I e

[jira] [Updated] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-10722: - Description: I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I e

[jira] [Updated] (KAFKA-10722) Timestamped store is used even if not desired

[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-10722: - Description: I have a stream which I then group and aggregate (this results in a KTable). When aggregating, I e

[jira] [Created] (KAFKA-10722) Timestamped store is used even if not desired

fml2 created KAFKA-10722: Summary: Timestamped store is used even if not desired Key: KAFKA-10722 URL: https://issues.apache.org/jira/browse/KAFKA-10722 Project: Kafka Issue Type: Bug Compo

[jira] [Commented] (KAFKA-9781) TimestampConverter / Allow to specify a time zone when converting unix epoch to string

[ https://issues.apache.org/jira/browse/KAFKA-9781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17135169#comment-17135169 ] fml2 commented on KAFKA-9781: - I've created [https://github.com/apache/kafka/pull/8869] for t

[jira] [Updated] (KAFKA-9781) TimestampConverter / Allow to specify a time zone when converting unix epoch to string

[ https://issues.apache.org/jira/browse/KAFKA-9781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] fml2 updated KAFKA-9781: Description: TimestampConverter can convert a unix epoch value (long; number of milliseconds since Jan 01 1970 00: