java.lang.ClassCastException: KafkaStreamsSpike$BusinessProcess cannot be cast to [B


Solutions on the web

Solution icon of googlegroups
via Google Groups by vivek sharma, 8 months ago
KafkaStreamsSpike$BusinessProcess cannot be cast to [B

Stack trace

java.lang.ClassCastException: KafkaStreamsSpike$BusinessProcess cannot be cast to [B
	at org.apache.kafka.common.serialization.ByteArraySerializer.serialize(ByteArraySerializer.java:18)
	at org.apache.kafka.streams.processor.internals.RecordCollector.send(RecordCollector.java:77)
	at org.apache.kafka.streams.processor.internals.SinkNode.process(SinkNode.java:72)
	at org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187)
	at org.apache.kafka.streams.kstream.internals.KStreamMap$KStreamMapProcessor.process(KStreamMap.java:43)
	at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:68)
	at org.apache.kafka.streams.processor.internals.StreamTask.forward(StreamTask.java:338)
	at org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:187)
	at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:64)
	at org.apache.kafka.streams.processor.internals.StreamTask.process(StreamTask.java:174)
	at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:320)
	at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:218)

Write tip

You have a different solution? A short tip here would help you and many other users who saw this issue last week.

Users with the same issue

2 times, 10 months ago