[
https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16752960#comment-16752960
]
ASF GitHub Bot commented on KAFKA-3522:
---
mjsax commented on pull request #6170: KAF
[
https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16752981#comment-16752981
]
ASF GitHub Bot commented on KAFKA-3522:
---
mjsax commented on pull request #6204: KAF
[
https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee Dongjin resolved KAFKA-7840.
Resolution: Fixed
> Documentation for cleanup.policy is out of date
> -
[
https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee Dongjin updated KAFKA-7840:
---
Fix Version/s: 2.1.1
2.2.0
> Documentation for cleanup.policy is out of date
> ---
[
https://issues.apache.org/jira/browse/KAFKA-7837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin P. McCabe updated KAFKA-7837:
---
Fix Version/s: 2.1.1
> maybeShrinkIsr may not reflect OfflinePartitions immediately
> ---
Christopher S Lester created KAFKA-7874:
---
Summary: NPE thrown while instantiating a KafkaStreams. object
Key: KAFKA-7874
URL: https://issues.apache.org/jira/browse/KAFKA-7874
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christopher S Lester updated KAFKA-7874:
Description:
I'm seeing an exception thrown when instantiating a KafkaStreams objec
[
https://issues.apache.org/jira/browse/KAFKA-7874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christopher S Lester updated KAFKA-7874:
Description:
I'm seeing an exception thrown when instantiating a KafkaStreams objec
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16753293#comment-16753293
]
ASF GitHub Bot commented on KAFKA-4217:
---
mjsax commented on pull request #5273: KAF
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4217:
---
Description:
{{KStream.transform}} gives you access to state stores while allowing you to
re
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-4217.
Resolution: Fixed
Fix Version/s: 2.2.0
> KStream.transform equivalent of flatMap
> -
[
https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-7875:
---
Description:
Part of KIP-313:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-313%3A+
Matthias J. Sax created KAFKA-7875:
--
Summary: Add KStream#flatTransformValues
Key: KAFKA-7875
URL: https://issues.apache.org/jira/browse/KAFKA-7875
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4217:
---
Labels: api newbie (was: api needs-kip newbie)
> KStream.transform equivalent of flatMap
> -
[
https://issues.apache.org/jira/browse/KAFKA-7875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-7875:
--
Assignee: Bruno Cadonna
> Add KStream#flatTransformValues
> --
[
https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16753295#comment-16753295
]
Matthias J. Sax commented on KAFKA-4217:
Using KAFKA-7875 to track the second par
16 matches
Mail list logo
