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

See

Re: [VOTE] 2.4.0 RC2

Hi all, I'd like to submit https://issues.apache.org/jira/browse/KAFKA-9258 for blocker consideration. This issue affects the Connect framework and causes a 500 error to be thrown from the REST API when restarting a task that has failed during startup, even after the connector has been

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

See

Jenkins build is back to normal : kafka-2.3-jdk8 #142

See

[jira] [Created] (KAFKA-9261) NPE when updating client metadata

Jason Gustafson created KAFKA-9261: -- Summary: NPE when updating client metadata Key: KAFKA-9261 URL: https://issues.apache.org/jira/browse/KAFKA-9261 Project: Kafka Issue Type: Bug

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

See Changes: [ismael] KAFKA-9156: Fix LazyTimeIndex & LazyOffsetIndex concurrency (#7760) -- [...truncated 2.70 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Created] (KAFKA-9260) Improve Serde "push down" and "wrapping"

Matthias J. Sax created KAFKA-9260: -- Summary: Improve Serde "push down" and "wrapping" Key: KAFKA-9260 URL: https://issues.apache.org/jira/browse/KAFKA-9260 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

Matthias J. Sax created KAFKA-9259: -- Summary: suppress() for windowed-Serdes does not work with default serdes Key: KAFKA-9259 URL: https://issues.apache.org/jira/browse/KAFKA-9259 Project: Kafka

Re: [VOTE] 2.4.0 RC2

Hi all, I ran the following: $ git clone https://github.com/elalonde/kafka $ ./kafka/bin/verifykafka-rc.sh 2.4.0 https://home.apache.org/~manikumar/kafka-2.4.0-rc2 - All sha1, sha256 and md5 sums look

[jira] [Created] (KAFKA-9258) Connect ConnectorStatusMetricsGroup sometimes NPE

Cyrus Vafadari created KAFKA-9258: - Summary: Connect ConnectorStatusMetricsGroup sometimes NPE Key: KAFKA-9258 URL: https://issues.apache.org/jira/browse/KAFKA-9258 Project: Kafka Issue

RE: [EXTERNAL] Re: [VOTE] KIP-280: Enhanced log compaction

Thanks Jun and added new recommendation for the consumer in the KIP. As we have 3 +1 building votes (Guozhang, Matthias & Jun), considering this KIP as accepted. Regards, Senthil -Original Message- From: Jun Rao Sent: Wednesday, November 27, 2019 9:16 AM To: dev Subject: [EXTERNAL]

SSLAuthentication Exception JMX

Hi! I ran into an issue over the weekend where our automated system updated some of our brokers with a certificate signed by a new certificate authority but didn't update the truststore on the other brokers. I've dumped the stacktrace in a gist

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

See Changes: [mimaison] KAFKA-9255: Add 'timestamp' field to 'message' entry (#7764) -- [...truncated 2.76 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

See Changes: [mimaison] KAFKA-9255: Add 'timestamp' field to 'message' entry (#7764) -- [...truncated 2.75 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Resolved] (KAFKA-9164) Don't evict active topics' metadata from the producer's cache

[ https://issues.apache.org/jira/browse/KAFKA-9164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne resolved KAFKA-9164. Resolution: Invalid Marking issue invalid since the producer logic was actually handling this

Re: JIRA Permissions Request

Hey Alex, I've added you. Let me know if you have any trouble with it. Thanks for your interest in helping out! -John On Mon, Dec 2, 2019, at 06:48, Alex Mironov wrote: > Hey folks, > > Would you kindly add me (username: amironov) to the JIRA contributors list > so that I can assign

Broker Interceptors

Hi Kafka community, I am hoping to get some feedback and thoughts about broker interceptors. KIP-42 Added Producer and Consumer interceptors which have provided Kafka users the ability to collect client side metrics and trace the path of individual messages end-to-end. This KIP also mentioned

JIRA Permissions Request

Hey folks, Would you kindly add me (username: amironov) to the JIRA contributors list so that I can assign https://issues.apache.org/jira/browse/KAFKA-9156 on myself? Thanks! -Alex

[jira] [Resolved] (KAFKA-9255) MessageSet v1 protocol wrong specification

[ https://issues.apache.org/jira/browse/KAFKA-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9255. --- Fix Version/s: 2.5.0 Resolution: Fixed > MessageSet v1 protocol wrong specification >

Handling deserialization exceptions in Kafka consumer

Hi all, I was recently discussing deserialization errors and how they can be handled in Kafka consumers. I believe the current code still throws an exception if deserialization fails which stops consumption unless you seek past that record. This creates an issue for a JDBC sink connector that

Re: [ANNOUNCE] Apache Kafka 2.2.2

Hi, May I know how would this version be different from the later versions 2.3.0, 2.3.1. I'm looking to upgrade my current Kafka 2.1.0, so can you please let me know what differences it would make for upgrading to 2.2.2 or 2.3.1? Thanks, Vinay On Monday, December 2, 2019, Vahid Hashemian wrote:

[jira] [Created] (KAFKA-9257) Allow listeners to bind on same port but different interfaces

Gérald Quintana created KAFKA-9257: -- Summary: Allow listeners to bind on same port but different interfaces Key: KAFKA-9257 URL: https://issues.apache.org/jira/browse/KAFKA-9257 Project: Kafka

Re: Broker Interceptors

Hi Tom, On Mon, 2 Dec 2019 at 09:41, Thomas Aley wrote: > Hi Kafka community, > > I am hoping to get some feedback and thoughts about broker interceptors. > > KIP-42 Added Producer and Consumer interceptors which have provided Kafka > users the ability to collect client side metrics and trace

[jira] [Created] (KAFKA-9256) mirrorMaker + kafka = java.lang.NoSuchMethodError: org.apache.kafka.common.requests.MetadataResponse.prepareResponse

Rudik created KAFKA-9256: Summary: mirrorMaker + kafka = java.lang.NoSuchMethodError: org.apache.kafka.common.requests.MetadataResponse.prepareResponse Key: KAFKA-9256 URL: