EFAK icon indicating copy to clipboard operation
EFAK copied to clipboard

Published 20 hours ago • verified publisher icon smartloli

After using mock to send message , consumer paused with exception .

Open JacobAP opened this issue 3 years ago • 1 comments

image

Exception in thread "main" org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition topic_1-0 at offset 23143. If needed, please seek past the record to continue consumption.
Caused by: org.apache.kafka.common.errors.SerializationException: Size of data received by IntegerDeserializer is not 4

JacobAP avatar Dec 24 '21 14:12 JacobAP

mock use StringSerializer as KEY_SERIALIZER, but i usually use IntegerSerializer as KEY_SERIALIZER image

JacobAP avatar Dec 24 '21 14:12 JacobAP