Почему новый потребитель Microsoft Kafkanet Kafka 0.8 не работает с брокером 0,9?
Согласно @Lundahl, "брокер 0,9 будет работать с... потребителем 0,8". Является ли потребитель Kafka 0,9 обратно совместимым?
Однако мы не считаем, что это относится к недавно выпущенной библиотеке https://github.com/Microsoft/Kafkanet. Первоначально он был написан для Kafka 0.8.x, и нам бы хотелось, чтобы он работал с Kafka 0.9.x. Мы смогли заставить производителя kafkanet работать с одним незначительным изменением кода. Однако потребитель кафканет, оказывается сложнее.
ПОДХОД 1: Нужно ли что-то, в частности, потребителю 0.8, чтобы заявить о себе как потребителе 0.8, чтобы брокер 0.9 мог правильно с ним взаимодействовать?
ПОДХОД 2: Альтернативно, есть ли какие-либо предложения по обновлению протокола и преобразованию кода для потребителя 0,9? Мы получаем ошибку в следующей строке кода в файле FetchResponse.cs, где 0,8 возвращает 1, а 0,9 возвращает 0 для dataCount.
size = reader.ReadInt32();
correlationId = reader.ReadInt32();
dataCount = reader.ReadInt32();
var data = new TopicData[dataCount];
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol
Любой другой совет, чтобы заставить потребителя kafkanet работать с 0,9 был бы признателен.
Спасибо,
-John