In case if we want to add heartbeat to a connect that using schema registry and subject name strategy like:
value.subject.name.strategy = io.confluent.kafka.serializers.subject.TopicRecordNameStrategy
we do get the following error:
org.apache.kafka.common.errors.SerializationException: In configuration value.subject.name.strategy = io.confluent.kafka.serializers.subject.TopicRecordNameStrategy, the message value must only be a record schema
Is there any workaround can be applied or we need to implement custom serializer that will skip heartbeat messages?
1 Like