[jira] [Created] (KAFKA-6018) Make from KafkaFuture.Function java 8 lambda compatible

Steven Aerts created KAFKA-6018: --- Summary: Make from KafkaFuture.Function java 8 lambda compatible Key: KAFKA-6018 URL: https://issues.apache.org/jira/browse/KAFKA-6018 Project: Kafka Issue

[jira] [Updated] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Aerts updated KAFKA-6018: Summary: Make KafkaFuture.Function java 8 lambda compatible (was: Make from KafkaFuture.Function

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194427#comment-16194427 ] Steven Aerts commented on KAFKA-6018: - I do not mind to create a KIP for this or start a [DISCUSS]

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16194404#comment-16194404 ] Steven Aerts commented on KAFKA-6018: - This does not work, as you cannot use java 8 lambdas with

[jira] [Commented] (KAFKA-6018) Make KafkaFuture.Function java 8 lambda compatible

[ https://issues.apache.org/jira/browse/KAFKA-6018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16275494#comment-16275494 ] Steven Aerts commented on KAFKA-6018: -

[jira] [Commented] (KAFKA-6717) TopicPartition Assined twice to a consumer group for 2 consumer instances

[ https://issues.apache.org/jira/browse/KAFKA-6717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522372#comment-16522372 ] Steven Aerts commented on KAFKA-6717: - I think this problem is a duplicate of [KAFKA-7026]. >

[jira] [Commented] (KAFKA-6681) Two instances of kafka consumer reading the same partition within a consumer group

[ https://issues.apache.org/jira/browse/KAFKA-6681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522373#comment-16522373 ] Steven Aerts commented on KAFKA-6681: - I think this problem is a duplicate of [KAFKA-7026]. > Two

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522404#comment-16522404 ] Steven Aerts commented on KAFKA-7026: - I found three issues in kafka which are I think all the same.

[jira] [Comment Edited] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16522404#comment-16522404 ] Steven Aerts edited comment on KAFKA-7026 at 6/25/18 3:06 PM: -- I found three

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16523582#comment-16523582 ] Steven Aerts commented on KAFKA-7026: - [~nperiwal] looking at the code of the {{RangeAssignor}}, I do

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16530876#comment-16530876 ] Steven Aerts commented on KAFKA-7026: - Just fyi, An extra example of a double assignment with a

[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689278#comment-16689278 ] Steven Aerts commented on KAFKA-7635: - Similar but focusses on a specific issue. > FetcherThread

[jira] [Created] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

Steven Aerts created KAFKA-7635: --- Summary: FetcherThread stops processing after "Error processing data for partition" Key: KAFKA-7635 URL: https://issues.apache.org/jira/browse/KAFKA-7635 Project:

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16637302#comment-16637302 ] Steven Aerts commented on KAFKA-7026: - [~nperiwal] no, I do not think so, as that one is "stateless",

[jira] [Commented] (KAFKA-7026) Sticky assignor could assign a partition to multiple consumers (KIP-341)

[ https://issues.apache.org/jira/browse/KAFKA-7026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16639667#comment-16639667 ] Steven Aerts commented on KAFKA-7026: - [~nperiwal] I propose that you create a separate ticket. As

[jira] [Updated] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Steven Aerts updated KAFKA-7635: Description: After disabling unclean leader leader again after recovery of a situation where we

[jira] [Commented] (KAFKA-7635) FetcherThread stops processing after "Error processing data for partition"

[ https://issues.apache.org/jira/browse/KAFKA-7635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16691337#comment-16691337 ] Steven Aerts commented on KAFKA-7635: - To give you an idea a code change which we think might resolve

[jira] [Commented] (KAFKA-8477) Cannot consume and request metadata for __consumer_offsets topic in Kafka 2.2

[ https://issues.apache.org/jira/browse/KAFKA-8477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17011524#comment-17011524 ] Steven Aerts commented on KAFKA-8477: - Wondering if this might be related to the fix done in