Re: Kafka Streams Testing Suite Question

I assume you are referring to the `TopologyTestDriver`? How do you pass/specify the serdes? For `TestInputTopic` and `TestOutputTopic` you would pass (de)serializer instances and thus you will need to call `configure()` in your test code explicitly. Similarly, if you pass `Serde` instances v

Re: [kafka-clients] [VOTE] 2.7.2 RC0

Mickael, For patch or bug fix releases like this one, should we exclude the Javadocs and site docs if they have not changed? https://github.com/apache/kafka-site The site docs were last changed about 6 months ago and it appears it may not have changed or needs validation On Tue, Oct 12, 2021

[VOTE] 2.7.2 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 2.7.2. Apache Kafka 2.7.2 is a bugfix release and 26 issues, as well as CVE-2021-38153, have been fixed since 2.7.1. Release notes for the 2.7.2 release: https://home.apache.org/~mimaison

Re: does kafka provide REST API for producing events to topic?

The Confluent REST Proxy provides a REST API for producing simple messages to the broker Confluent REST Proxy API Reference | Confluent Documentation On Tue, Oct 12, 2021 at 10:21 AM Steven Miller wrote: > What about > https://www

Re: does kafka provide REST API for producing events to topic?

What about https://www.confluent.io/blog/http-and-rest-api-use-cases-and-architecture-with-apache-kafka/? Would that work for this use case? -Steve > On Oct 12, 2021, at 8:32 AM, Luke Chen wrote: > > Hi Pushkar, >> I would like to know if kafka also provides any REST API which can > be

回复: how to restore kafka and mm2 after disaster

even I successfully rebuild src kafka and topic/consumer group/acl in src kafka, when I test, I noticed consumer offset in src kafka is out of sync with dst kafka's, so how do we fail-back to src kafka if disaster is recovered, thanks 发件人: Calvin Chen 发送时间: 202

[VOTE] 2.6.3 RC0

Hello Kafka users, developers and client-developers, This is the first candidate for release of Apache Kafka 2.6.3. Apache Kafka 2.6.3 is a bugfix release and 11 issues, as well as CVE-2021-38153, have been fixed since 2.6.2. Release notes for the 2.6.3 release: https://home.apache.org/~mimaison

Re: does kafka provide REST API for producing events to topic?

Hi Pushkar, > I would like to know if kafka also provides any REST API which can be accessed by the test client (rather than making a TCP connection to broker) and then invoking those REST API to produce events onto topics? --> Sorry, Kafka only provides TCP connection to brokers. Thank you. Luke

does kafka provide REST API for producing events to topic?

Hi All, I am trying to load test our application that is a consumer of a kafka topic. I want to load test the application wherein my test tool (jmeter script) is making a connection to kafka broker and then producing events onto topic through producer API. This requires that the test client has co

how to restore kafka and mm2 after disaster

Hi all I know kafka mm2 works good, it can mirror topic/message/offset to remote cluster, it is quite good, but I have question on how we restore cluster and mirror after disaster, let's say: I have src kafka mirror to dst kafka, and mm2 works well, then src kafka/zookeeper get disaster and co