Hi all, I would like to ask some questions.
our company env:
Broker version: 1.0.1
producer use kafka-client version: 1.0.1
consumer use kafka-client version: 0.10.2.2
the producer send record and the record with header,
the consumer can not consume the record and out a WARN LOG at
`org.apache.kafka.clients.consumer.internals.Fetcher` log.warn("Unknown error
fetching data for topic-partition {}", tp);
the Stack is
parseCompletedFetch:844, Fetcher (org.apache.kafka.clients.consumer.internals)
fetchedRecords:482, Fetcher (org.apache.kafka.clients.consumer.internals)
pollOnce:1038, KafkaConsumer (org.apache.kafka.clients.consumer)
poll:996, KafkaConsumer (org.apache.kafka.clients.consumer)
run:201, CaseController$ConsumerThread
(test.org.apache.skywalking.apm.testcase.kafka.controller)
Because we have so many projects, in the tens of thousands
The question I want to ask is, without upgrading consumer Kafka-Client version,
one，what configuration does the 1.0.1 Version Broker have that allows it to sit
down and be compatible with a lower consumer kafka-client version like 0.10.2.2
Kafka pulling messages, such as removing headers, or something better than that?
two，Where can I see all the kafka-Client versions of the subscribed Topic?
three，What better way to be compatible with this situation?
Thank You
