[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-09 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17489636#comment-17489636 ] Ulrik commented on KAFKA-13638: --- [~cadonna]  Very strange. I added the same code as you an

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-04 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17487211#comment-17487211 ] Ulrik commented on KAFKA-13638: --- [~cadonna] i ran the test from within Intellij and just t

[jira] [Comment Edited] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-03 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486529#comment-17486529 ] Ulrik edited comment on KAFKA-13638 at 2/3/22, 6:28 PM: Hi [~cad

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-03 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486565#comment-17486565 ] Ulrik commented on KAFKA-13638: --- [~cadonna] Done. Average time for the test was the same a

[jira] [Comment Edited] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-03 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486529#comment-17486529 ] Ulrik edited comment on KAFKA-13638 at 2/3/22, 3:05 PM: Hi [~cad

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-03 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486529#comment-17486529 ] Ulrik commented on KAFKA-13638: --- Hi [~cadonna], I forked the repo and added a test. Here'

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-02 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486257#comment-17486257 ] Ulrik commented on KAFKA-13638: --- I tried the following combination of versions: * strea

[jira] [Commented] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-02 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17486102#comment-17486102 ] Ulrik commented on KAFKA-13638: --- [~mjsax] I can confirm that using an in-memory store work

[jira] [Updated] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-02 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ulrik updated KAFKA-13638: -- Description: I have a topology where I stream messages from an input topic, transform the message to multiple

[jira] [Created] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-02 Thread Ulrik (Jira)
Ulrik created KAFKA-13638: - Summary: Slow KTable update when forwarding multiple values from transformer Key: KAFKA-13638 URL: https://issues.apache.org/jira/browse/KAFKA-13638 Project: Kafka Issue

[jira] [Updated] (KAFKA-13638) Slow KTable update when forwarding multiple values from transformer

2022-02-02 Thread Ulrik (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ulrik updated KAFKA-13638: -- Description: I have a topology where I stream messages from an input topic, transform the message to multiple