I was able to resolved this issue. Let me answer my question here.  I have removed Deserializer from connector properties . consumer.key.deserializer=org.apache.kafka.common.serialization.StringDeserializer //Kafka Serializer class for Kafka record values, we have set our message body to be String consumer.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer     And I have also published the kafka topic to event hub platform. But Deserializer properties seems to be main reason for this issue. It is working good now. ... View more