Re: [External] : Re: Unit Test falling for Kafka 2.8.0

Hi Mohammad, I can't see your report. But usually we won't run all tests on local environment. If you want to submit PR to Kafka repo, there will be jenkins build/tests for you. And also, there are some flaky tests. You can check the jenkins build results for v3.0 here: https://ci-builds.apache.or

How to properly use a clean a TimestampedKeyValueStore

Hello I'm using Kafka Streams and I have a transformer that uses a TimestampedKeyValueStore, I have a punctuator that is in charge of cleaning the store, Basically I'm iterating the store using kvStore.all() and deleting the keys based on some logic with kvStore.delete(key); I'm seeing the chang

Glue avro schema registry with flink and kafka for any object

I am trying to registry and serialize an abject with flink, kafka, glue and avro. I've seen this method which I'm trying. Schema schema = parser.parse(new File("path/to/avro/file")); GlueSchemaRegistryAvroSerializationSchema test= GlueSchemaRegistryAvroSerializationSchema.forGeneric(schema, topic,

Re: [External] : Re: Unit Test falling for Kafka 2.8.0

Thanks a lot Luke for this piece of information. Yesterday i downloaded kafka 3.0 and its even falling there. Do i need to take it from git as i tool from https://kafka.apache.org/downloads

Re: Unit Test falling for Kafka 2.8.0

Hi Mohammad This is a known issue because of JFrog sunset the Bintray repo. We've fixed this issue in v3.0 (PR: https://github.com/apache/kafka/pull/10056). You should build/run tests successfully in v3.0. If you can't change to v3.0, then you can refer to the PR above to fix it. But we're not sur

Unit Test falling for Kafka 2.8.0

Hi all, Need some assistance as unit test is falling for kafka 2.8.0 , below are detail. Appreciate any guidance , Please redirect me to correct audience if i am firing this email to wrong audience. I have downloaded kafka 2.8.0 source code (from https://kafka.apache.org/downloads ) and build