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

See

What happened to KIP-158?

Hi, KIP-158 proposed a way to allow source connectors a way to configure their topics prior to creation. This was discussed, but the vote didn't get enough commiter votes at the time (though I think a couple of the +1s came from people who are now committers). Meanwhile in KIP-382 (MirrorMaker 2.

[DISCUSS] KIP-549: Surface Consumer's Metadata in KafkaAdminClient#describeConsumerGroups

Hi all, I wrote a short KIP to surface the consumer's metadata in the `describeConsumerGroups` of the `KafkaAdminClient`. The metadata is already present in the protocol but not exposed yet. I think that it is handy when troubleshooting consumer groups. https://cwiki.apache.org/confluence/display

KAFKA-5008

Hello Why https://issues.apache.org/jira/browse/KAFKA-5008 has been idle for so long? The pull request looks solid. https://github.com/apache/kafka/pull/2882 Madis Parn

Re: What happened to KIP-158?

Hey Tom. The approach I ended up taking with MM2 is to construct an AdminClient based on properties in the connector config, which requires that such properties exist in two places (the worker config and the connector config). I still believe that, ideally, a connector implementer should have acces

[jira] [Created] (KAFKA-9229) initTransactions() fails when running new producer against an old server

Steven Zhang created KAFKA-9229: --- Summary: initTransactions() fails when running new producer against an old server Key: KAFKA-9229 URL: https://issues.apache.org/jira/browse/KAFKA-9229 Project: Kafka

kafka connect incoming port

Hello, I am working on setting up a Kafka Connect JMS Source to pull data from an external IBM MQ and push to an internal Kafka topic. We will have a firewall between the external MQ and the internal Connect so I need to do a firewall exception. The network people are asking for the incomin

Connect port

Hello, I am working on setting up a Kafka Connect JMS Source to pull data from an external IBM MQ and push to an internal Kafka topic. We will have a firewall between the external MQ and the internal Connect so I need to do a firewall exception. The network people are asking for the incoming p

Re: Preliminary blog post about the Apache Kafka 2.4.0 release

Manikumar, One thing I had previously missed, should we mention the upgrade to ZK 3.5? Ismael On Thu, Nov 14, 2019 at 10:41 AM Manikumar wrote: > Hi all, > > I've prepared a preliminary blog post about the upcoming Apache Kafka 2.4.0 > release. > Please take a look and let me know if you want

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

See Changes: [bill] MINOR: Updated StreamTableJoinIntegrationTest to use TTD (#7722) -- [...truncated 2.69 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldPa

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

See Changes: [github] KAFKA-9229: Fix incompatible change in InitProducerIdRequest (#7746) -- [...truncated 2.75 MB...] org.apache.kafka.streams.internals.KeyValueStoreFa