[jira] [Commented] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

2019-12-18 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999649#comment-16999649 ] Alex Kokachev commented on KAFKA-9011: -- [~bbejeck], [~vvcephei], could you guys plea

[jira] [Comment Edited] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

2019-10-20 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955734#comment-16955734 ] Alex Kokachev edited comment on KAFKA-8939 at 10/21/19 3:58 AM: ---

[jira] [Commented] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

2019-10-20 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16955734#comment-16955734 ] Alex Kokachev commented on KAFKA-8939: -- [https://builds.apache.org/job/kafka-pr-jdk1

[jira] [Commented] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

2019-10-17 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16953583#comment-16953583 ] Alex Kokachev commented on KAFKA-9011: -- [~cadonna], raised PR [https://github.com/ap

[jira] [Commented] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

2019-10-10 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16949002#comment-16949002 ] Alex Kokachev commented on KAFKA-9011: -- I came up with the code below. If it's accep

[jira] [Updated] (KAFKA-9011) Add KStream#flatTransform and KStream#flatTransformValues to Scala API

2019-10-10 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Kokachev updated KAFKA-9011: - Summary: Add KStream#flatTransform and KStream#flatTransformValues to Scala API (was: Add KStrea

[jira] [Updated] (KAFKA-9011) Add KStream#transformValues and KStream#flatTransformValues to Scala API

2019-10-10 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Kokachev updated KAFKA-9011: - Description: Part of KIP-313:  [https://cwiki.apache.org/confluence/display/KAFKA/KIP-313%3A+Add+

[jira] [Updated] (KAFKA-9011) Add KStream#transformValues and KStream#flatTransformValues to Scala API

2019-10-09 Thread Alex Kokachev (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alex Kokachev updated KAFKA-9011: - Description: Part of KIP-313:  [https://cwiki.apache.org/confluence/display/KAFKA/KIP-313%3A+Add+

[jira] [Created] (KAFKA-9011) Add KStream#transformValues and KStream#flatTransformValues to Scala API

2019-10-09 Thread Alex Kokachev (Jira)
Alex Kokachev created KAFKA-9011: Summary: Add KStream#transformValues and KStream#flatTransformValues to Scala API Key: KAFKA-9011 URL: https://issues.apache.org/jira/browse/KAFKA-9011 Project: Kafka