Сжатие кафки на стороне потребителя - PullRequest
Новая
       7

Сжатие кафки на стороне потребителя

0 голосов
/ 10 января 2020

Я включил мгновенное сжатие на стороне производителя со следующим изменением: 

props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG,"snappy");

Теперь, если для этого потребуются какие-либо изменения на стороне потребителя? Я проверил Consumer.config, но не нашел там никакого параметра обжатия.

И когда я запустил этот код, сообщения не приходят на потребительскую сторону, и я получаю следующую ошибку: 

[1/10/20 17:25:39:759 UTC] 00018027 org.apache.kafka.clients.consumer.KafkaConsumer              I [Consumer clientId=com.ora.def.lieo, groupId=group-cedm] Seeking to offset 320 for partition Party-Resolved-Check-0
[1/10/20 17:25:49:760 UTC] 00018029 com.ibm.cedm.kafka.KafkaConsumerService                      E Received exception when fetching the next record from Party-Resolved-Check-0. If needed, please seek past the record to continue consumption.

1 Ответ

1 голос
/ 11 января 2020

Конфигурация декомпрессии не требуется. Потребители автоматически справляются с этим.

Непонятно, как ваша ошибка связана со сжатием

...