[jira] [Created] (KAFKA-15216) InternalSinkRecord::newRecord method ignores the headers argument

Yash Mayya created KAFKA-15216: -- Summary: InternalSinkRecord::newRecord method ignores the headers argument Key: KAFKA-15216 URL: https://issues.apache.org/jira/browse/KAFKA-15216 Project: Kafka

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

See

[jira] [Created] (KAFKA-15215) The default.dsl.store config is not compatible with custom state stores

A. Sophie Blee-Goldman created KAFKA-15215: -- Summary: The default.dsl.store config is not compatible with custom state stores Key: KAFKA-15215 URL: https://issues.apache.org/jira/browse/KAFKA-15215

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

See Changes: -- [...truncated 386545 lines...] Gradle Test Run :streams:integrationTest > Gradle Test Executor 182 > StoreQueryIntegrationTest > shouldQuerySpecificStaleP

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.4 #150

See

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

See Changes: -- [...truncated 562642 lines...] > Task :group-coordinator:testClasses UP-TO-DATE > Task :connect:json:testJar > Task :connect:json:testSrcJar > Task :metadata:co

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #182

See Changes: -- [...truncated 254261 lines...] org.apache.kafka.streams.integration.StreamStreamJoinIntegrationTest > testMultiInner[caching enabled = true] STARTED org.apa

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

See Changes: -- [...truncated 383898 lines...] org.apache.kafka.connect.integration.ExactlyOnceSourceIntegrationTest.testConnectorReconfiguration failed, log available in

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi Federico/Omnia, Generally I like the idea of deprecating and eventually removing "fix the bug" properties like this, but 4.0 may be a bit soon. I'm also unsure of how we would instruct users who are relying on the property being set to "false" to migrate to a version of MM2 that doesn't support

[jira] [Reopened] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reopened KAFKA-14669: --- > Include MirrorMaker connector configurations in docs > ---

[jira] [Created] (KAFKA-15214) Add metrics for OffsetOutOfRangeException when tiered storage is enabled

Lixin Yao created KAFKA-15214: - Summary: Add metrics for OffsetOutOfRangeException when tiered storage is enabled Key: KAFKA-15214 URL: https://issues.apache.org/jira/browse/KAFKA-15214 Project: Kafka

[jira] [Created] (KAFKA-15213) Provide the exact offset to QuorumController.replay

Colin McCabe created KAFKA-15213: Summary: Provide the exact offset to QuorumController.replay Key: KAFKA-15213 URL: https://issues.apache.org/jira/browse/KAFKA-15213 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-15212) Remove classgraph license

Divij Vaidya created KAFKA-15212: Summary: Remove classgraph license Key: KAFKA-15212 URL: https://issues.apache.org/jira/browse/KAFKA-15212 Project: Kafka Issue Type: Bug Reporte

[jira] [Created] (KAFKA-15211) DistributedConfigTest#shouldFailWithInvalidKeySize fails when run after TestSslUtils#generate

Greg Harris created KAFKA-15211: --- Summary: DistributedConfigTest#shouldFailWithInvalidKeySize fails when run after TestSslUtils#generate Key: KAFKA-15211 URL: https://issues.apache.org/jira/browse/KAFKA-15211

[jira] [Resolved] (KAFKA-10775) DOAP has incorrect category

[ https://issues.apache.org/jira/browse/KAFKA-10775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-10775. Fix Version/s: 3.1.0 Assignee: Sebb Resolution: Fixed > DOAP has incorrect

Re: [DISCUSS] KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy

Hi Federico, I don't have any strong opinion one way or the other. The pro of deprecation is not adding more configs to MM2 as it has too many configs already. However, we need to think about old MM2 migrating their internal topics to 4.0 with less impact. @Chris what do you think? Cheers Omnia

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

See Changes: -- [...truncated 386567 lines...] at app//org.junit.jupiter.api.AssertTrue.failNotTrue(AssertTrue.java:63) at app//org.junit.jupiter.api.Assert

[jira] [Created] (KAFKA-15210) Mention vote should be open for at atleast 72 hours

Divij Vaidya created KAFKA-15210: Summary: Mention vote should be open for at atleast 72 hours Key: KAFKA-15210 URL: https://issues.apache.org/jira/browse/KAFKA-15210 Project: Kafka Issue Typ

Re: KIP-919: Allow AdminClient to Talk Directly with the KRaft Controller Quorum

H Colin, Thanks for the KIP. Just a few points: 1. As Tom mentioned it would be good to clarify the APIs we expect available on controllers. I assume we want to add DESCRIBE_CONFIGS as part of this KIP. 2. Currently we have no way of retrieving the list of configs that apply to controllers. It wo

[jira] [Created] (KAFKA-15209) Need Help on ssl.provider

Suryanarayana Garlapati created KAFKA-15209: --- Summary: Need Help on ssl.provider Key: KAFKA-15209 URL: https://issues.apache.org/jira/browse/KAFKA-15209 Project: Kafka Issue Type: B

[jira] [Created] (KAFKA-15208) Upgrade Jackson dependencies to version 2.15.2

Said BOUDJELDA created KAFKA-15208: -- Summary: Upgrade Jackson dependencies to version 2.15.2 Key: KAFKA-15208 URL: https://issues.apache.org/jira/browse/KAFKA-15208 Project: Kafka Issue Type

[jira] [Created] (KAFKA-15207) ProducerIdManager#generateProducerId() should return different error code for newer clients

Jeff Kim created KAFKA-15207: Summary: ProducerIdManager#generateProducerId() should return different error code for newer clients Key: KAFKA-15207 URL: https://issues.apache.org/jira/browse/KAFKA-15207 P

[jira] [Resolved] (KAFKA-14669) Include MirrorMaker connector configurations in docs

[ https://issues.apache.org/jira/browse/KAFKA-14669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14669. --- Fix Version/s: 3.6.0 Resolution: Done > Include MirrorMaker connector configurations

[jira] [Resolved] (KAFKA-14953) Add metrics for tiered storage

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Divij Vaidya resolved KAFKA-14953. -- Resolution: Fixed > Add metrics for tiered storage > -- > >

Re: [VOTE] 3.5.1 RC1

Thank you for testing folks. Although, we already have 3 binding votes, as per Apache's release approval process [1], I am going to keep the vote open for 72 hours, i.e. until July 20th 10:30 AM (CEST) [1] https://www.apache.org/legal/release-policy.html#release-approval -- Divij Vaidya On Tu

[jira] [Created] (KAFKA-15206) Flaky test RemoteIndexCacheTest.testClose()

Divij Vaidya created KAFKA-15206: Summary: Flaky test RemoteIndexCacheTest.testClose() Key: KAFKA-15206 URL: https://issues.apache.org/jira/browse/KAFKA-15206 Project: Kafka Issue Type: Test

Re: [VOTE] 3.5.1 RC1

Hi Divij, I verified the checksums and signatures, ran the ZooKeeper quickstart with the 2.13 binaries, ran the tests on Java 11 and checked the javadoc and licenses. +1 (binding) Thanks, Mickael On Tue, Jul 18, 2023 at 8:32 AM Luke Chen wrote: > > Hi Divij, > > I've run: > 1. Download kafka_2

[jira] [Created] (KAFKA-15205) ShutdownableThread

Divij Vaidya created KAFKA-15205: Summary: ShutdownableThread Key: KAFKA-15205 URL: https://issues.apache.org/jira/browse/KAFKA-15205 Project: Kafka Issue Type: Bug Affects Versions: 3.4.

Re: [VOTE] KIP-852: Optimize calculation of size for log in remote tier

Thank you everyone for your participation. The KIP is accepted and vote is now closed with: 3 binding votes (Satish, Luke, John) 2 non-binding votes (Kamal, Jorge) -- Divij Vaidya On Tue, Jul 18, 2023 at 1:04 PM Satish Duggana wrote: > +1 > Thanks Divij for addressing the comments in the KI

Re: [REVIEW REQUEST] KAFKA-14591 DeleteRecordsCommand moved to tools

Federico, thanks for the review. https://github.com/apache/kafka/pull/13278 - committers review required. Dear committers, please, take a look. > 10 июля 2023 г., в 17:23, Николай Ижиков написал(а): > > Fixed all comments and checkstyle issues. > Please, make one more round of review. > >> 1

Re: TLS/SSL

Hi Jim, Thank you very much! Regards! Am Di., 18. Juli 2023 um 14:20 Uhr schrieb Jim Halfpenny : > Hi Hamza, > TLS for Kafka is not implemented in any significantly different way > compared to other TLS-enabled services. A good place to start with is the > Apache Kafka documentation: > > [image

Re: TLS/SSL

Hi Hamza, TLS for Kafka is not implemented in any significantly different way compared to other TLS-enabled services. A good place to start with is the Apache Kafka documentation: https://kafka.apache.org/090/documentation.html#security_ssl Apache Kafka kafka.apache.org You’ll find a lot of ot

Re: [DISCUSS] KIP-953: partition method to be overloaded to accept headers as well.

Hey @Sagar, Thank you for the response and feedback. 1. Done 2. Yeah, that was a mistake from my end. Corrected. 3. Can you please elaborate this, I have added the java doc along with the code changes. Should I paste the same in KIP too? 4. Moved. 5. I have added one more use ca

TLS/SSL

Hi, Can someone explain to me the architecture of how SSL works in Kafka? The whole truststore and keystore relationship and how it works. Thanks in advance! -- *Hamze HAMZE* Trainee/Apprentice/VIE +49 (0) 90926032877 hamze.ha...@valeo.com Valeo Schalter und Sensoren GmbH Valeostrasse 1 - 8665

Request permission to contribute

Hello, I would like to get permission to contribute to the Apache Kafka project. Specifically I would like to create KIP for Kafka Streams and to work on the implementation for that KIP. My JIRA and Confluence ID is the same and it is: igorf211 Regards, Igor Fomenko

Re: [VOTE] KIP-852: Optimize calculation of size for log in remote tier

+1 Thanks Divij for addressing the comments in the KIP. LGTM. ~Satish. On Thu, 13 Jul 2023 at 18:10, Jorge Esteban Quilcate Otoya wrote: > > +1 (non-binding) > > Thanks for the KIP! > > Jorge. > > On Thu, 13 Jul 2023 at 12:26, Luke Chen wrote: > > > +1 (binding) from me. > > > > Thanks for the

[jira] [Created] (KAFKA-15204) Replication Throttling: Re-add ReplicationThrottledRate to Server Config

Nikos Kostoulas created KAFKA-15204: --- Summary: Replication Throttling: Re-add ReplicationThrottledRate to Server Config Key: KAFKA-15204 URL: https://issues.apache.org/jira/browse/KAFKA-15204 Projec

[jira] [Created] (KAFKA-15203) Remove dependency on Reflections

Divij Vaidya created KAFKA-15203: Summary: Remove dependency on Reflections Key: KAFKA-15203 URL: https://issues.apache.org/jira/browse/KAFKA-15203 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-951: Leader discovery optimisations for the client

Hi Mayank, Thanks for the KIP! Some questions: 1. I can see most of the cases we only care about consumer fetch from the leader. But what if the consumer was fetching from the follower? We already include `PreferredReadReplica` in the fetch response. Should we put the node info of PreferredReadRe