Сообщения о распаковке KafkaSpout(Storm)

Я использую KafkaSpout для приема сообщений от Kafka.

Сообщения создаются с помощью org.apache.kafka.clients.producer.KafkaProducer сжатия gzip props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip");

Как установить тип сжатия в KafkaSpout для использования несжатых сообщений?


apache-kafka kafka-consumer-api apache-storm
person Alex Stanovsky    schedule 14.03.2016    source источник
comment
Согласно этой странице, это может быть обработано автоматически. Вы получаете ошибки?   -  person Kit Menke    schedule 14.03.2016

Ответы (1)


arrow_upward
0
arrow_downward

сжатие gzip выполняется автоматически. Если это текстовый файл, вы можете напрямую читать входной поток или XML-файлы, которые вы анализируете как обычные файлы.

Свойство props.put(ProducerConfig.COMPRESSION_TYPE_CONFIG, "gzip"); не требуется.

Если есть какие-либо ошибки, пожалуйста, напишите об этом.

person Vijay Innamuri    schedule 15.03.2016