[jira] [Updated] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-6366: --- Fix Version/s: 1.0.1 > StackOverflowError in kafka-coordinator-heartbeat-thread >

[jira] [Commented] (KAFKA-6366) StackOverflowError in kafka-coordinator-heartbeat-thread

[ https://issues.apache.org/jira/browse/KAFKA-6366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324992#comment-16324992 ] Jason Gustafson commented on KAFKA-6366: [~joerg.heinicke] Thanks for the debug lo

[jira] [Comment Edited] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group

[ https://issues.apache.org/jira/browse/KAFKA-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324830#comment-16324830 ] Vahid Hashemian edited comment on KAFKA-6434 at 1/13/18 5:18 AM: ---

[jira] [Commented] (KAFKA-4499) Add "getAllKeys" API for querying windowed KTable stores

[ https://issues.apache.org/jira/browse/KAFKA-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324869#comment-16324869 ] ASF GitHub Bot commented on KAFKA-4499: --- guozhangwang closed pull request #4385: [KA

[jira] [Commented] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller

[ https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324857#comment-16324857 ] Ivan Babrou commented on KAFKA-6441: Looks like the issue is in Sarama, which only rea

[jira] [Resolved] (KAFKA-6441) FetchRequest populates buffer of size MinBytes, even if response is smaller

[ https://issues.apache.org/jira/browse/KAFKA-6441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Babrou resolved KAFKA-6441. Resolution: Invalid > FetchRequest populates buffer of size MinBytes, even if response is smaller >

[jira] [Commented] (KAFKA-6309) add support for getting topic defaults from AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324854#comment-16324854 ] ASF GitHub Bot commented on KAFKA-6309: --- guozhangwang opened a new pull request #442

[jira] [Commented] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group

[ https://issues.apache.org/jira/browse/KAFKA-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324830#comment-16324830 ] Vahid Hashemian commented on KAFKA-6434: [~cabot] This is fixed in the current tru

[jira] [Commented] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group

[ https://issues.apache.org/jira/browse/KAFKA-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324760#comment-16324760 ] Satyajit varma commented on KAFKA-6434: --- [~cabot] it is because your Consumer Group

[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&focusedCommentId=16324658#comment-16324658 ] ASF GitHub Bot commented on KAFKA-6018: --- ewencp closed pull request #4033: KAFKA-601

[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&focusedCommentId=16324659#comment-16324659 ] ASF GitHub Bot commented on KAFKA-6018: --- steven-aerts opened a new pull request #403

[jira] [Assigned] (KAFKA-6434) Kafka-consumer-groups.sh reset-offsets does not work properly for not existing group

[ https://issues.apache.org/jira/browse/KAFKA-6434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-6434: -- Assignee: Vahid Hashemian > Kafka-consumer-groups.sh reset-offsets does not work proper

[jira] [Commented] (KAFKA-5540) Deprecate and remove internal converter configs

[ https://issues.apache.org/jira/browse/KAFKA-5540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324350#comment-16324350 ] Randall Hauch commented on KAFKA-5540: -- [KIP-174|https://cwiki.apache.org/confluence/

[jira] [Commented] (KAFKA-6443) KTable involved in multiple joins could result in duplicate results

[ https://issues.apache.org/jira/browse/KAFKA-6443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324283#comment-16324283 ] Guozhang Wang commented on KAFKA-6443: -- The two duplicate records will be the same, s

[jira] [Commented] (KAFKA-5117) Kafka Connect REST endpoints reveal Password typed values

[ https://issues.apache.org/jira/browse/KAFKA-5117?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16324215#comment-16324215 ] Randall Hauch commented on KAFKA-5117: -- So I'm a bit concerned that simply masking th

[jira] [Commented] (KAFKA-6204) Interceptor and MetricsReporter should implement java.io.Closeable

[ https://issues.apache.org/jira/browse/KAFKA-6204?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16323797#comment-16323797 ] Charly Molter commented on KAFKA-6204: -- This is stuck on the java8 upgrade so we can

[jira] [Assigned] (KAFKA-5890) records.lag should use tags for topic and partition rather than using metric name.

[ https://issues.apache.org/jira/browse/KAFKA-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charly Molter reassigned KAFKA-5890: Assignee: Charly Molter > records.lag should use tags for topic and partition rather than u

[jira] [Assigned] (KAFKA-6310) ConcurrentModificationException when reporting requests-in-flight in producer

[ https://issues.apache.org/jira/browse/KAFKA-6310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charly Molter reassigned KAFKA-6310: Assignee: Charly Molter > ConcurrentModificationException when reporting requests-in-flight

[jira] [Updated] (KAFKA-6180) Add a Validator for NonNull configurations and remove redundant null checks on lists

[ https://issues.apache.org/jira/browse/KAFKA-6180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Charly Molter updated KAFKA-6180: - Fix Version/s: 1.1.0 > Add a Validator for NonNull configurations and remove redundant null checks

[jira] [Commented] (KAFKA-6442) Catch 22 with cluster rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16323763#comment-16323763 ] Andreas commented on KAFKA-6442: For what is worth, restarting node4 (for maintenance) see

[jira] [Commented] (KAFKA-6442) Catch 22 with cluster rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16323747#comment-16323747 ] Andreas commented on KAFKA-6442: Thanks for the reply. I am afraid "unclean.leader.electio