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

See

[jira] [Created] (KAFKA-12765) NPE using SASL when following JavaSpec

Walenwein created KAFKA-12765: - Summary: NPE using SASL when following JavaSpec Key: KAFKA-12765 URL: https://issues.apache.org/jira/browse/KAFKA-12765 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Thanks once again for the KIP and the updates, Chris. As mentioned in my prior email, here are my more general comments/questions (other than my earlier question about the transaction boundaries). Hopefully these are readable: The worker-level offset.flush.timeout.ms property will be ignored for

[jira] [Created] (KAFKA-12764) Exapnd Gradle build for Scala 3.0 ?

Dejan Stojadinović created KAFKA-12764: -- Summary: Exapnd Gradle build for Scala 3.0 ? Key: KAFKA-12764 URL: https://issues.apache.org/jira/browse/KAFKA-12764 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Thanks again for the continued improvements to this KIP, Chris. I have a number of questions that I'll enumerate in a subsequent email, but first I wanted to make a higher-level comment. I don't know what to make about the proposal to rely upon the existing offset commit interval as the way to

Re: [DISCUSS] KIP-618: Atomic commit of source connector records and offsets

Thanks for continuing to work on this KIP, Chris. On Fri, May 7, 2021 at 12:58 PM Chris Egerton wrote: > b) An annotation is a really cool way to allow connector developers to > signal eligibility for exactly-once to Connect (and possibly, through > Connect, to users). Like you mention,

Build failed in Jenkins: Kafka » kafka-2.5-jdk8 #46

See Changes: -- [...truncated 4.89 MB...] kafka.admin.ReassignPartitionsCommandArgsTest > shouldNotAllowExecuteWithBrokers PASSED

Build failed in Jenkins: Kafka » kafka-2.4-jdk8 #27

See Changes: -- [...truncated 3.18 MB...] org.apache.kafka.common.network.SslSelectorTest > testRenegotiationFails PASSED org.apache.kafka.common.network.SslSelectorTest >

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #122

See Changes: -- [...truncated 6.35 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldCloseProcessor[Eos enabled = false] PASSED

Re: [VOTE] KIP-731: Record Rate Limiting for Kafka Connect

Thank you for the KIP. I need this feature. +1 (non-binding) Thanks, Dongjin On Thu, Apr 29, 2021 at 9:34 AM Ryanne Dolan wrote: > Hey y'all, I'd like to start the vote on KIP-731, which enables operators > to limit Connector throughput. > > >