one of my client is written in GO and they are using the sarama 1.0.0 library and my kafka is of 1.1.1 version without any security. when client is trying to consume from the topic they are not able to consume and they are getting exception as

There’s two independent systems which produce kafka messages with different information in two independent topics, about the same entity. Let’s say we have Entity with ID 123, Topic A contains quantity information about Entity 123 and Topic B contains the title for Entity 123.