spring-kafka

spring-kafka copied to clipboard

Kakfa -> Kafka

wpbs

It would be great, if you could add an example that uses JUnit5 with `@EmbeddedKafka`. Thanks! :)

carlspring

java.nio.file.FileSystemException: C:\Users\AppData\Local\Temp\kafka-8364428204801180638\version-2\log.1: The process cannot access the file because it is being used by another process.

3

I've started the Zookeeper on as shown below ``` 2018-12-16 12:20:58,109 [myid:] - INFO [main:Environment@100] - Server environment:java.io.tmpdir=C:\Users\e081155\AppData\Local\Temp\ 2018-12-16 12:20:58,110 [myid:] - INFO [main:Environment@100] - Server environment:java.compiler= 2018-12-16 12:20:58,113 [myid:]...

ghost

Getting ClassCast Exception : GenericData$Record cannot be cast to org.apache.avro.specific.SpecificRecordBase

1

While using the given AvroSerializer and Deserializer in Serde with Kafka streams , I am facing ClassCastException GenericData$Record cannot be cast to org.apache.avro.specific.SpecificRecordBase. config.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.serdeFrom(new AvroSerializer() , new AvroDeserializer(MemberMeasureKey.class)).getClass()); config.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG,...

ghost