Re: Hi / Requesting permission to create KIP

Hi Guozhang, Yes, it was granted earlier today. Thank you! Cheers, Kowshik On Fri, Mar 20, 2020 at 8:59 PM Guozhang Wang wrote: > Hello Kowshik, > > I saw your username is granted the permission already on wiki. > > Cheers, > Guozhang > > > On Fri, Mar 20, 2020 at 5:13 PM Kowshik Prakasam

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

[ 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

Re: Hi / Requesting permission to create KIP

Hello Kowshik, I saw your username is granted the permission already on wiki. Cheers, Guozhang On Fri, Mar 20, 2020 at 5:13 PM Kowshik Prakasam wrote: > Hi, > > I'm looking for permission to create a KIP under > > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals

Jenkins build is back to normal : kafka-trunk-jdk11 #1268

See

Build failed in Jenkins: kafka-2.5-jdk8 #69

See Changes: [konstantine] MINOR: Use Exit.exit instead of System.exit in MM2 (#8321) -- [...truncated 2.91 MB...] org.apache.kafka.streams.MockProcessorContextTest >

Build failed in Jenkins: kafka-trunk-jdk8 #4347

See Changes: [github] KAFKA-9727: cleanup the state store for standby task dirty close and -- [...truncated 5.91 MB...] org.apache.kafka.streams.TopologyTestDriverTest

Re: [VOTE] 2.5.0 RC2

Hi Boyang, Is this a regression? Ismael On Fri, Mar 20, 2020, 5:43 PM Boyang Chen wrote: > Hey David, > > I would like to raise https://issues.apache.org/jira/browse/KAFKA-9701 as > a > 2.5 blocker. The impact of this bug is that it could throw fatal exception > and kill a stream thread on

Consumer Rebalancing Issues

Hi All, I have a Kafka Consumer that polls the data and gets *paused* for 15-20 mins for the post-processing of the polled records. However, during the time of pause, the broker assumes that the consumer group is dead(check below log) and rebalances the consumer group. *Application Log:*

Build failed in Jenkins: kafka-2.4-jdk8 #170

See Changes: [jason] KAFKA-9654; Update epoch in `ReplicaAlterLogDirsThread` after new -- [...truncated 2.76 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest

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

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

Re: [VOTE] 2.5.0 RC2

Hey David, I would like to raise https://issues.apache.org/jira/browse/KAFKA-9701 as a 2.5 blocker. The impact of this bug is that it could throw fatal exception and kill a stream thread on Kafka Streams level. It could also create a crashing scenario for plain Kafka Consumer users as well as the

Hi / Requesting permission to create KIP

Hi, I'm looking for permission to create a KIP under https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals . My username is 'kprakasam'. Could you please grant me access? Cheers, Kowshik

Build failed in Jenkins: kafka-trunk-jdk11 #1267

See Changes: [github] KAFKA-6145: Add constrained balanced assignment algorithm (#8262) -- [...truncated 5.95 MB...]

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

[ 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] [Resolved] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

[ 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 >

Re: Hi / Requesting permission to create KIP

Thanks a lot, Matthias! Cheers, Kowshik On Fri, Mar 20, 2020 at 3:55 PM Matthias J. Sax wrote: > Done. > > On 3/20/20 3:52 PM, Kowshik Prakasam wrote: > > Hey everyone, > > > > I'm looking for permission to create a KIP under > > >

Re: Hi / Requesting permission to create KIP

Done. On 3/20/20 3:52 PM, Kowshik Prakasam wrote: > Hey everyone, > > I'm looking for permission to create a KIP under > https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals > . > My username is 'kprakasam'. If you are an admin, and you are reading this > email, could

Hi / Requesting permission to create KIP

Hey everyone, I'm looking for permission to create a KIP under https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals . My username is 'kprakasam'. If you are an admin, and you are reading this email, could you please grant me access? Thank you. Cheers, Kowshik

Jenkins build is back to normal : kafka-trunk-jdk8 #4346

See

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

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:

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

[ 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 >

Jenkins build is back to normal : kafka-trunk-jdk11 #1266

See

Build failed in Jenkins: kafka-trunk-jdk8 #4345

See Changes: [github] KAFKA-9734: Fix IllegalState in Streams transit to standby (#8319) -- [...truncated 2.91 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: JMX expired topic metircs

Believe this is already fixed https://issues.apache.org/jira/browse/KAFKA-3572 On Thu, Mar 19, 2020 at 9:27 PM 张祥 wrote: > Hi, > > I notice that there are jmx metrics for deleted topics when using java code > and jmxterm. Has anyone also run into this ? If yes, what is the reason > behind this

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

[ 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

Re: [Vote] KIP-569: Update DescribeConfigsResponse to include additional metadata information

I have 3 +1s and 1 +1(non-binding) vote for this Kip. Thank you all for the feedback. I'll start working on the PR. Thanks Shailesh On Fri, Mar 20, 2020 at 8:35 AM Brian Byrne wrote: > +1 (non-binding) - thanks! > > My only suggestion would be to make the enum-to-int conversion explicit for >

Re: [Vote] KIP-569: Update DescribeConfigsResponse to include additional metadata information

+1 (non-binding) - thanks! My only suggestion would be to make the enum-to-int conversion explicit for the new ConfigType, with a surrounding comment, to ensure that no accidental reordering and for easier readability should the response message message be read. Brian On Fri, Mar 20, 2020 at

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

[ 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 >

Re: [Vote] KIP-569: Update DescribeConfigsResponse to include additional metadata information

+1 binding. Thanks for the KIP  -David On Tue, Mar 17, 2020 at 4:44 AM Rajini Sivaram wrote: > Hi Shailesh, > > +1 (binding) > > Thanks for the KIP! > > Regards, > > Rajini > > > On Tue, Mar 10, 2020 at 2:37 AM Gwen Shapira wrote: > > > +1 > > Looks great. Thanks for the proposal, Shailesh.

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

Artur created KAFKA-9739: Summary: StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode" Key: KAFKA-9739 URL:

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

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

Jenkins build is back to normal : kafka-trunk-jdk8 #4344

See

Build failed in Jenkins: kafka-trunk-jdk11 #1265

See Changes: [github] KAFKA-8820: kafka-reassign-partitions.sh should support the KIP-455 API [github] KAFKA-9553; Improve measurement for loading groups and transactions

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

[ 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

Jenkins build is back to normal : kafka-2.5-jdk8 #68

See

Build failed in Jenkins: kafka-trunk-jdk11 #1264

See Changes: [github] MINOR: Bump RocksDB version from 5.18.3 to 5.18.4 (#8284) [github] KAFKA-9654; Update epoch in `ReplicaAlterLogDirsThread` after new --

[jira] [Resolved] (KAFKA-9553) Transaction state loading metric does not count total loading time

[ https://issues.apache.org/jira/browse/KAFKA-9553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9553. Fix Version/s: 2.6.0 Resolution: Fixed > Transaction state loading metric does not

Build failed in Jenkins: kafka-trunk-jdk8 #4343

See Changes: [github] KAFKA-8820: kafka-reassign-partitions.sh should support the KIP-455 API -- [...truncated 2.91 MB...]