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

2021-02-20 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287774#comment-17287774 ] fml2 commented on KAFKA-12328: -- I now see that a processor / transformer is inherently "not thread safe"

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

2021-02-20 Thread fml2 (Jira)
[ 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

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

2021-02-20 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287625#comment-17287625 ] fml2 commented on KAFKA-12328: -- Just to let you know: After I changed the supplier implementation to always

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

2021-02-19 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287386#comment-17287386 ] fml2 edited comment on KAFKA-12328 at 2/19/21, 9:53 PM: {quote}In general, the

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

2021-02-19 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287386#comment-17287386 ] fml2 commented on KAFKA-12328: -- {quote}In general, the ideas of the "supplier pattern" is _inherently_ to

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

2021-02-19 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287372#comment-17287372 ] fml2 edited comment on KAFKA-12328 at 2/19/21, 9:50 PM: {quote}ie, the supplier

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

2021-02-19 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287372#comment-17287372 ] fml2 commented on KAFKA-12328: -- {quote}ie, the supplier must return a new object each time it's invoked

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

2021-02-19 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287103#comment-17287103 ] fml2 edited comment on KAFKA-12328 at 2/19/21, 5:42 PM: Hrm... It's weird, but:

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

2021-02-19 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287103#comment-17287103 ] fml2 commented on KAFKA-12328: -- Hrm... It's weird, but: My setup is: I have three partitions and two nodes

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

2021-02-18 Thread fml2 (Jira)
[ 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

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

2021-02-17 Thread fml2 (Jira)
[ 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

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

2021-02-17 Thread fml2 (Jira)
[ 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),

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

2021-02-16 Thread fml2 (Jira)
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

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

2020-11-17 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17234030#comment-17234030 ] fml2 commented on KAFKA-10722: -- I've created [https://github.com/apache/kafka/pull/9606] and

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

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

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

2020-11-16 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17233116#comment-17233116 ] fml2 commented on KAFKA-10722: -- OK, I accept that Kafka Streams needs timestamps for the internal

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

2020-11-14 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231981#comment-17231981 ] fml2 commented on KAFKA-10722: -- Matthias, does your response mean that we *always* get a timestamped store?

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

2020-11-14 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231972#comment-17231972 ] fml2 edited comment on KAFKA-10722 at 11/14/20, 10:29 AM: -- Hello, thank you

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

2020-11-14 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17231972#comment-17231972 ] fml2 commented on KAFKA-10722: -- Hello, thank you for the quick response! This perfectly makes sense. Could

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

2020-11-13 Thread fml2 (Jira)
[ 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

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

2020-11-13 Thread fml2 (Jira)
[ 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

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

2020-11-13 Thread fml2 (Jira)
[ 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

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

2020-11-13 Thread fml2 (Jira)
[ 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

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

2020-11-13 Thread fml2 (Jira)
[ 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

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

2020-11-13 Thread fml2 (Jira)
[ 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

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

2020-11-13 Thread fml2 (Jira)
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

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

2020-06-14 Thread fml2 (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9781?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135169#comment-17135169 ] fml2 commented on KAFKA-9781: - I've created [https://github.com/apache/kafka/pull/8869] for this. >

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

2020-04-21 Thread fml2 (Jira)
[ 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