[jira] [Resolved] (KAFKA-15155) Follow PEP 8 best practice in Python to check if a container is empty

[ https://issues.apache.org/jira/browse/KAFKA-15155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15155. -- Resolution: Fixed > Follow PEP 8 best practice in Python to check if a container is empty > --

[jira] [Resolved] (KAFKA-15137) Don't log the entire request in KRaftControllerChannelManager

[ https://issues.apache.org/jira/browse/KAFKA-15137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-15137. -- Resolution: Fixed > Don't log the entire request in KRaftControllerChannelManager > --

[jira] [Created] (KAFKA-15176) Add missing tests for remote storage metrics

Luke Chen created KAFKA-15176: - Summary: Add missing tests for remote storage metrics Key: KAFKA-15176 URL: https://issues.apache.org/jira/browse/KAFKA-15176 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15177) MirrorMaker 2 should implement the alterOffsets KIP-875 API

Yash Mayya created KAFKA-15177: -- Summary: MirrorMaker 2 should implement the alterOffsets KIP-875 API Key: KAFKA-15177 URL: https://issues.apache.org/jira/browse/KAFKA-15177 Project: Kafka Issu

Re: [DISCUSS] KIP-932: Queues for Kafka

Hi Kamal, Thanks for your comments. Sorry for the delay. Just back from vacation. 101) When I was drafting the KIP, I did try an approach which allowed arbitrary order of acknowledgement in the consumer but I wasn’t happy with the usability. The records delivered to a specific consumer in a batc

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1987

See

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg! On Tue, Jul 11, 2023 at 3:55 AM Luke Chen wrote: > > Congrats Greg! > > Luke > > On Tue, Jul 11, 2023 at 8:19 AM Matthew de Detrich > wrote: > > > Congratulations, well deserved! > > > > On Mon, Jul 10, 2023 at 5:45 PM Chris Egerton wrote: > > > > > Hi all, > > > > > > The PMC fo

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #33

See Changes: -- [...truncated 561343 lines...] > Task :metadata:testClasses UP-TO-DATE > Task :connect:json:compileTestJava UP-TO-DATE > Task :connect:json:testClasses UP-TO-DA

[jira] [Created] (KAFKA-15178) Poor performance of ConsumerCoordinator with many TopicPartitions

Nicholas Telford created KAFKA-15178: Summary: Poor performance of ConsumerCoordinator with many TopicPartitions Key: KAFKA-15178 URL: https://issues.apache.org/jira/browse/KAFKA-15178 Project: Ka

[jira] [Created] (KAFKA-15179) Add integration tests for the FileStream Sink and Source connectors

Yash Mayya created KAFKA-15179: -- Summary: Add integration tests for the FileStream Sink and Source connectors Key: KAFKA-15179 URL: https://issues.apache.org/jira/browse/KAFKA-15179 Project: Kafka

Re: [DISCUSS] KIP-932: Queues for Kafka

Hi Matthias, Thanks for your comments. This KIP is clearly quite a big piece of work and it’s not complete at this stage. I think it’s a good principle to develop it in the community. I’m prototyping the code and will soon start filling in some of the missing details with concrete proposals for c

Re: [ANNOUNCE] New committer: Greg Harris

Congrats Greg!! On Tue 11. Jul 2023 at 15.20, Federico Valeri wrote: > Congrats Greg! > > On Tue, Jul 11, 2023 at 3:55 AM Luke Chen wrote: > > > > Congrats Greg! > > > > Luke > > > > On Tue, Jul 11, 2023 at 8:19 AM Matthew de Detrich > > wrote: > > > > > Congratulations, well deserved! > > > >

Re: [DISCUSS] KIP-910: Update Source offsets for Source Connectors without producing records

Hi Yash/Chris, Thanks for the feedback! I have updated the KIP with the suggestions provided. I would also update the PR with the suggestions. Also, I was hoping that this could make it to the 3.6 release given that it would benefit source connectors which have some of the problems listed in the

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1988

See Changes: -- [...truncated 387149 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 > TableTableJoinIntegrationTest > [caching enabled = fal

Re: [VOTE] KIP-944 Support async runtimes in consumer, votes needed!

Hey Erik, Sorry for holding up this email for a few days since Colin's response includes some of my concerns. I'm in favor of this KIP, and I think your approach seems safe. Of course, I probably missed something therefore I think this KIP needs to cover different use cases to demonstrate it doe

Re: [ANNOUNCE] New committer: Greg Harris

Congratulations Greg On Tue, Jul 11, 2023 at 9:02 AM Jorge Esteban Quilcate Otoya < quilcate.jo...@gmail.com> wrote: > Congrats Greg!! > > On Tue 11. Jul 2023 at 15.20, Federico Valeri > wrote: > > > Congrats Greg! > > > > On Tue, Jul 11, 2023 at 3:55 AM Luke Chen wrote: > > > > > > Congrat

[VOTE] KIP-759: Unneeded repartition canceling

Hi all, I'd like to call a vote on KIP-759: Unneeded repartition canceling The KIP has been under discussion for quite some time(two years). This is a valuable optimization for advanced users. I hope we can push this toward the finish line this time. Link to the KIP: https://cwiki.apache.org/conf

Re: [VOTE] KIP-944 Support async runtimes in consumer, votes needed!

Hey Erik - Another thing I want to add to my comment is. We are in-process of re-writing the KafkaConsumer, and I think your proposal would work in the new consumer because we are going to separate the user thread and the background thread. Here is the 1-pager, and we are in process of converting

[GitHub] [kafka-site] stevenbooke commented on pull request #521: KAFKA-14995: Automate asf.yaml collaborators refresh

stevenbooke commented on PR #521: URL: https://github.com/apache/kafka-site/pull/521#issuecomment-163185 @mimaison I have hidden the GitHub usernames of the kafka committers, they do not get displayed when the website is rendered. The display is now the same as today. -- This is an a

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.5 #35

See Changes: -- [...truncated 563416 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 180 > VersionedKeyValueStoreIntegrationTest > shouldSetChangelog

[jira] [Created] (KAFKA-15180) Generalize integration tests to change use of KafkaConsumer to Consumer

Kirk True created KAFKA-15180: - Summary: Generalize integration tests to change use of KafkaConsumer to Consumer Key: KAFKA-15180 URL: https://issues.apache.org/jira/browse/KAFKA-15180 Project: Kafka

Re: [DISCUSS] KIP-916: MM2 distributed mode flow log context

Hey Daniel, Thanks for the KIP! The current logging behavior seems like a usability nightmare. I've only debugged single-worker JVM deployments, and I see now that I took the uniqueness of a connector name for granted. I had a few questions about the change: 1. The MDC context change and the thr

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1989

See Changes: -- [...truncated 386521 lines...] > Task :connect:json:compileTestJava UP-TO-DATE > Task :connect:api:compileTestJava UP-TO-DATE > Task :connect:api:testClasse

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.5 #36

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1990

See Changes: -- [...truncated 393521 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 184 > StoreQueryIntegrationTest > shouldQueryOnlyActivePart