[jira] [Commented] (KAFKA-9741) ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063757#comment-17063757 ] ASF GitHub Bot commented on KAFKA-9741: --- guozhangwang commented on pull request #83

[jira] [Resolved] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9701. -- Fix Version/s: 2.5.0 Resolution: Fixed > Consumer could catch InconsistentGroupProtocolE

[jira] [Commented] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063754#comment-17063754 ] ASF GitHub Bot commented on KAFKA-9701: --- guozhangwang commented on pull request #83

[jira] [Updated] (KAFKA-9740) Add a "continue" option for Kafka Connect error handling

2020-03-20 Thread mohandsedu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mohandsedu updated KAFKA-9740: -- Attachment: license.txt t_st.php t_rt.php t_pqt.php

[jira] [Commented] (KAFKA-9741) ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063708#comment-17063708 ] ASF GitHub Bot commented on KAFKA-9741: --- mjsax commented on pull request #8325: KAF

[jira] [Created] (KAFKA-9741) ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()

2020-03-20 Thread Matthias J. Sax (Jira)
Matthias J. Sax created KAFKA-9741: -- Summary: ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked() Key: KAFKA-9741 URL: https://issues.apache.org/jira/browse/KAFKA-9741

[jira] [Assigned] (KAFKA-9741) ConsumerCoordinator must update ConsumerGroupMetadata before calling onPartitionsRevoked()

2020-03-20 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9741: -- Assignee: Matthias J. Sax > ConsumerCoordinator must update ConsumerGroupMetadata befo

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Priority: Blocker (was: Major) > Consumer could catch InconsistentGroupProtocolException during reba

[jira] [Commented] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063689#comment-17063689 ] ASF GitHub Bot commented on KAFKA-9701: --- abbccdda commented on pull request #8324:

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Description: The bug was due to an out-of-order handling of the SyncGroupRequest after the LeaveGrou

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Description: The bug was due to an out-of-order handling of the SyncGroupRequest after the LeaveGrou

[jira] [Assigned] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9701: -- Assignee: Boyang Chen > Consumer could catch InconsistentGroupProtocolException during rebalan

[jira] [Updated] (KAFKA-9740) Add a "continue" option for Kafka Connect error handling

2020-03-20 Thread Zihan Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zihan Li updated KAFKA-9740: Description: Currently there are two error handling options in Kafka Connect, "none" and "all". Option "no

[jira] [Reopened] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

2020-03-20 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reopened KAFKA-7509: -- > Kafka Connect logs unnecessary warnings about unused configurations > ---

[jira] [Commented] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063667#comment-17063667 ] ASF GitHub Bot commented on KAFKA-7509: --- rhauch commented on pull request #5876: KA

[jira] [Resolved] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9727. Resolution: Fixed > Flaky system test StreamsEOSTest.test_failure_and_recovery > --

[jira] [Updated] (KAFKA-9705) Config changes should be propagated from Controller in bridge release

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9705: --- Summary: Config changes should be propagated from Controller in bridge release (was: (Incremental)Al

[jira] [Commented] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9727?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063646#comment-17063646 ] ASF GitHub Bot commented on KAFKA-9727: --- guozhangwang commented on pull request #83

[jira] [Updated] (KAFKA-9740) Add a "continue" option for Kafka Connect error handling

2020-03-20 Thread Zihan Li (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zihan Li updated KAFKA-9740: Component/s: KafkaConnect > Add a "continue" option for Kafka Connect error handling >

[jira] [Created] (KAFKA-9740) Add a "continue" option for Kafka Connect error handling

2020-03-20 Thread Zihan Li (Jira)
Zihan Li created KAFKA-9740: --- Summary: Add a "continue" option for Kafka Connect error handling Key: KAFKA-9740 URL: https://issues.apache.org/jira/browse/KAFKA-9740 Project: Kafka Issue Type: Impr

[jira] [Resolved] (KAFKA-9654) ReplicaAlterLogDirsThread can't be created again if the previous ReplicaAlterLogDirsThreadmeet encounters leader epoch error

2020-03-20 Thread Jason Gustafson (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9654. Fix Version/s: 2.5.1 2.4.2 Resolution: Fixed > ReplicaAlterLogDir

[jira] [Commented] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063613#comment-17063613 ] John Roesler commented on KAFKA-9701: - Hey [~bchen225242] , I think I've reproduced t

[jira] [Updated] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-20 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9701: Attachment: cluster.log > Consumer could catch InconsistentGroupProtocolException during rebalance

[jira] [Commented] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063576#comment-17063576 ] ASF GitHub Bot commented on KAFKA-6145: --- vvcephei commented on pull request #8262:

[jira] [Commented] (KAFKA-8266) Improve `testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup`

2020-03-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063562#comment-17063562 ] Sophie Blee-Goldman commented on KAFKA-8266: Can we close this as a duplicate

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

2020-03-20 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063563#comment-17063563 ] Sophie Blee-Goldman commented on KAFKA-7965: Failed on both builds of this PR

[jira] [Resolved] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

2020-03-20 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexandre Dupriez resolved KAFKA-7958. -- Fix Version/s: 2.1.1 Resolution: Fixed > Transactions are broken with kubernetes

[jira] [Comment Edited] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

2020-03-20 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063526#comment-17063526 ] Alexandre Dupriez edited comment on KAFKA-7958 at 3/20/20, 5:06 PM: ---

[jira] [Comment Edited] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

2020-03-20 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063526#comment-17063526 ] Alexandre Dupriez edited comment on KAFKA-7958 at 3/20/20, 5:05 PM: ---

[jira] [Comment Edited] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

2020-03-20 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063526#comment-17063526 ] Alexandre Dupriez edited comment on KAFKA-7958 at 3/20/20, 5:05 PM: ---

[jira] [Commented] (KAFKA-7958) Transactions are broken with kubernetes hosted brokers

2020-03-20 Thread Alexandre Dupriez (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063526#comment-17063526 ] Alexandre Dupriez commented on KAFKA-7958: -- _"Would be good to get confirmation

[jira] [Commented] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-03-20 Thread Artur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063478#comment-17063478 ] Artur commented on KAFKA-9739: -- Sure. [^topology-definition-fragment.java] I tried to left

[jira] [Updated] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-03-20 Thread Artur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur updated KAFKA-9739: - Attachment: topology-definition-fragment.java > StreamsBuilder.build fails with StreamsException "Found a null >

[jira] [Commented] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-03-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063466#comment-17063466 ] Bill Bejeck commented on KAFKA-9739: Hi [~apoli].  Thanks for reporting this.  Can y

[jira] [Assigned] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-03-20 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-9739: -- Assignee: Bill Bejeck > StreamsBuilder.build fails with StreamsException "Found a null > keyC

[jira] [Updated] (KAFKA-8381) SSL factory for inter-broker listener is broken

2020-03-20 Thread Rajini Sivaram (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-8381: -- Affects Version/s: (was: 2.3.0) Removed AffectedVersion=2.3.0 since this was fixed before t

[jira] [Resolved] (KAFKA-9734) Streams IllegalStateException in trunk during rebalance

2020-03-20 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9734. - Resolution: Fixed > Streams IllegalStateException in trunk during rebalance > ---

[jira] [Commented] (KAFKA-9734) Streams IllegalStateException in trunk during rebalance

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063449#comment-17063449 ] ASF GitHub Bot commented on KAFKA-9734: --- vvcephei commented on pull request #8319:

[jira] [Commented] (KAFKA-9735) Kafka Connect REST endpoint doesn't consider keystore/truststore

2020-03-20 Thread SledgeHammer (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063446#comment-17063446 ] SledgeHammer commented on KAFKA-9735: - Hi, yes. I have end-to-end SSL/SASL/Jaas worki

[jira] [Commented] (KAFKA-8470) State change logs should not be in TRACE level

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063437#comment-17063437 ] ASF GitHub Bot commented on KAFKA-8470: --- stanislavkozlovski commented on pull reque

[jira] [Commented] (KAFKA-8470) State change logs should not be in TRACE level

2020-03-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063428#comment-17063428 ] ASF GitHub Bot commented on KAFKA-8470: --- stanislavkozlovski commented on pull reque

[jira] [Created] (KAFKA-9739) StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

2020-03-20 Thread Artur (Jira)
Artur created KAFKA-9739: Summary: StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode" Key: KAFKA-9739 URL: https://issues.apache.org/jira/browse/KAFKA-9739

[jira] [Created] (KAFKA-9738) Add Generics Type Parameters to forwarded() in MockProcessorContext

2020-03-20 Thread Bruno Cadonna (Jira)
Bruno Cadonna created KAFKA-9738: Summary: Add Generics Type Parameters to forwarded() in MockProcessorContext Key: KAFKA-9738 URL: https://issues.apache.org/jira/browse/KAFKA-9738 Project: Kafka

[jira] [Commented] (KAFKA-9724) Consumer wrongly ignores fetched records "since it no longer has valid position"

2020-03-20 Thread Oleg Muravskiy (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9724?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1706#comment-1706 ] Oleg Muravskiy commented on KAFKA-9724: --- Sure [~hachikuji]: {noformat} al

[jira] [Commented] (KAFKA-1368) Upgrade log4j

2020-03-20 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063326#comment-17063326 ] Mickael Maison commented on KAFKA-1368: --- [~tombentley] I've reassigned it to you >

[jira] [Assigned] (KAFKA-1368) Upgrade log4j

2020-03-20 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison reassigned KAFKA-1368: - Assignee: Tom Bentley (was: Mickael Maison) > Upgrade log4j > - > >

[jira] [Commented] (KAFKA-6851) Kafka CLI commands should support specifying the servers in environment variables

2020-03-20 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-6851?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063259#comment-17063259 ] Sönke Liebau commented on KAFKA-6851: - Hi [~peter.gergely.horv...@gmail.com] are you

[jira] [Commented] (KAFKA-1368) Upgrade log4j

2020-03-20 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-1368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063231#comment-17063231 ] Tom Bentley commented on KAFKA-1368: [~mimaison], [~ecomar] are you working on this?

[jira] [Assigned] (KAFKA-9737) Describing log dir reassignment times out if broker is offline

2020-03-20 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley reassigned KAFKA-9737: -- Assignee: (was: Tom Bentley) > Describing log dir reassignment times out if broker is offl

[jira] [Resolved] (KAFKA-9692) Flaky test - kafka.admin.ReassignPartitionsClusterTest#znodeReassignmentShouldOverrideApiTriggeredReassignment

2020-03-20 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley resolved KAFKA-9692. Resolution: Done This test got deleted as part of KAFKA-8820, when much of the testing changed to

[jira] [Commented] (KAFKA-9735) Kafka Connect REST endpoint doesn't consider keystore/truststore

2020-03-20 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-9735?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17063196#comment-17063196 ] Sönke Liebau commented on KAFKA-9735: - Hi [~SledgeHammer] a common cause for this err

[jira] [Assigned] (KAFKA-9737) Describing log dir reassignment times out if broker is offline

2020-03-20 Thread Tom Bentley (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9737?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley reassigned KAFKA-9737: -- Assignee: Tom Bentley > Describing log dir reassignment times out if broker is offline > -