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

See Changes: -- [...truncated 452761 lines...] [2023-03-17T01:41:10.413Z] > Task :core:compileJava NO-SOURCE [2023-03-17T01:41:10.413Z] > Task :clients:testClasses

[jira] [Created] (KAFKA-14816) Connect Http Client

Ian McDonald created KAFKA-14816: Summary: Connect Http Client Key: KAFKA-14816 URL: https://issues.apache.org/jira/browse/KAFKA-14816 Project: Kafka Issue Type: Bug Components:

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

See Changes: -- [...truncated 444965 lines...] [2023-03-16T18:16:59.545Z] > Task :connect:json:jar UP-TO-DATE [2023-03-16T18:16:59.545Z] > Task

[jira] [Created] (KAFKA-14815) Move Kafka documentation to Markdown/Hugo

Jorge Esteban Quilcate Otoya created KAFKA-14815: Summary: Move Kafka documentation to Markdown/Hugo Key: KAFKA-14815 URL: https://issues.apache.org/jira/browse/KAFKA-14815 Project:

[jira] [Created] (KAFKA-14814) Skip restart of connectors when redundant resume request is made

Chris Egerton created KAFKA-14814: - Summary: Skip restart of connectors when redundant resume request is made Key: KAFKA-14814 URL: https://issues.apache.org/jira/browse/KAFKA-14814 Project: Kafka

Re: [DISCUSSION] MirrorMaker2 offset translation for compacted, filtered, and transactional source topics

Thanks all for the discussion! Mickael, I agree. I think that while someone may appreciate the current high availability, everyone expects at-least-once delivery from this feature. Not meeting the expectation for at-least-once delivery may be more damaging than excessive re-delivery in a failure

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.3 #163

See

Re: [Discuss] KIP-581: Value of optional null field which has default value

Hi Mickael, Tom got this part perfect so I'm just going to copy+paste: Thanks to Cheng for the KIP and to you for picking it up. I'm wondering why we need separate properties for serialization vs. deserialization? If the converter is being used by the Kafka Connect runtime, a given instance of

Re: [DISCUSS] KIP-915: Next Gen Group Coordinator Downgrade Path

Hi Jeff, Thanks for the KIP! I am really glad that we are finally addressing this gap in KIP-848. I have a few general comments. 1. Overall, I feel like the important bits are not bold enough in the KIP. I think that it is good to explain the overall upgrade/downgrade process and to highlight

Re: [DISCUSS] KIP-914 Join Processor Semantics for Versioned Stores

Thanks for your comments, Matthias! > For stream-table joins, I think we need to elaborate that a `get(k, ts)` call now might return `null` if the history retention of the store is too short. Great callout -- I agree we should definitely clarify this in the KIP and mention it in the eventual

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

See Changes: -- [...truncated 503430 lines...] [2023-03-16T15:36:04.090Z] [2023-03-16T15:36:04.090Z] org.apache.kafka.streams.integration.StoreQueryIntegrationTest >

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

See

Re: [VOTE] KIP-911: Add source tag to MirrorSourceConnector metrics

+1 (binding). Thanks Mickael! On Thu, 16 Mar 2023 at 12:55, Chris Egerton wrote: > +1 (binding). Thanks for the KIP! > > On Wed, Mar 15, 2023 at 7:08 AM Mickael Maison > wrote: > > > Hi, > > > > I'd like to start the vote on KIP-911 to add the source cluster alias > > as a tag on the

Re: [Discuss] KIP-581: Value of optional null field which has default value

Hi Mickael, Thanks to Cheng for the KIP and to you for picking it up. My only comment (feel free to ignore) is about the names of the configs. Personally I don't think I'd correctly guess what "serialize.use.optional.null" meant. Something like "serialize.map.null.to.default" is much clearer to

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #100

See Changes: -- [...truncated 458270 lines...] [2023-03-16T15:31:35.585Z]

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #143

See Changes: -- [...truncated 293642 lines...] [2023-03-16T15:16:27.365Z] ZooKeeperClientTest > testZNodeChildChangeHandlerForChildChange() PASSED [2023-03-16T15:16:27.365Z]

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

See

[jira] [Created] (KAFKA-14813) Timeout Exception causes data loss

Nicola Stringari created KAFKA-14813: Summary: Timeout Exception causes data loss Key: KAFKA-14813 URL: https://issues.apache.org/jira/browse/KAFKA-14813 Project: Kafka Issue Type: Bug

Re: [DISCUSSION] MirrorMaker2 offset translation for compacted, filtered, and transactional source topics

"it becomes impossible to ensure that MM2 is able to sync offsets from consumer groups that are behind the last-synced offset emitted by MirrorSourceTask." That's sorta true. The idea is that offset syncs are exceptionally rare. They basically occur when the tasks start or restart and that should

Re: [DISCUSSION] MirrorMaker2 offset translation for compacted, filtered, and transactional source topics

Hi Greg, I agree with others that a KIP isn't necessarily required as long as we don't alter public interface. Reading between the lines (please correct me if I'm wrong), it seems like part of the concern is that the design of the offset syncs topic (parts of which are counted as part of the

[GitHub] [kafka-site] dariiagrim opened a new pull request, #498: Howly added to powered-by page

dariiagrim opened a new pull request, #498: URL: https://github.com/apache/kafka-site/pull/498 On behalf of the Howly team, I would like to add it to the powered-by page. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [VOTE] KIP-911: Add source tag to MirrorSourceConnector metrics

+1 (binding). Thanks for the KIP! On Wed, Mar 15, 2023 at 7:08 AM Mickael Maison wrote: > Hi, > > I'd like to start the vote on KIP-911 to add the source cluster alias > as a tag on the MirrorSourceConnector metrics: > >

[jira] [Resolved] (KAFKA-14809) Connect incorrectly logs that no records were produced by source tasks

[ https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14809. --- Resolution: Fixed > Connect incorrectly logs that no records were produced by source tasks

Re: [DISCUSS] Apache Kafka 3.5.0 release

Hi, This is a reminder that KIP freeze is less than a week away (22 Mar). For a KIP to be considered for this release, it must be voted and accepted by that date. Feature freeze will be 3 weeks after this, so if you want KIPs or other significant changes in the release, please get them ready

Re: [DISCUSSION] MirrorMaker2 offset translation for compacted, filtered, and transactional source topics

Hi Greg, Thanks for looking into this issue! To me the current behavior is just buggy. I don't see how anyone could rely on incorrect offset translation, at this point it's pretty much like picking a random offset when consumers start on the target cluster. Apart if we have to introduce new

[jira] [Created] (KAFKA-14812) ProducerPerformance still counting successful sending in console when sending failed

hudeqi created KAFKA-14812: -- Summary: ProducerPerformance still counting successful sending in console when sending failed Key: KAFKA-14812 URL: https://issues.apache.org/jira/browse/KAFKA-14812 Project: