apache-kafka

1зной

1ответ

Apache Kafka и Avro: org.apache.avro.generic.GenericData $ Запись не может быть отнесена к com.harmeetsingh13.java.Customer

Всякий раз, когда я пытаюсь прочитать сообщение из очереди kafka, я получаю следующее исключение: [error] (run-main-0) java.lang.ClassCastException: org.apache.avro.generic.GenericData$Record cannot b

2зной

3ответ

Как получить задержку kafka в java-программе

Я написал программу java, чтобы использовать messsage от kafka. Я хочу контролировать отставание потребления, как получить его через java? BTW, я использую: <groupId>org.apache.kafka</groupId> <artif

0зной

1ответ

Как сохранить потоковые данные из кластера Hadoop On-Premise в AWS S3

Мы запускаем потоковое приложение реального времени на Hortonworks, используя Kafka и Spark Streaming в настройках кластера On-Premise. У нас есть требование, чтобы нам нужно было вытолкнуть некоторые

0зной

2ответ

Voltdb - Kafka Importer - Изменить разделительный элемент, использованный для импорта

У меня есть тема kafka, ограниченная символом ";" и я хочу импортировать в таблицу voltdb. Я не нашел в официальной документации что-либо об изменении разделителя. Импортер Kafka (https://docs.voltdb.

0зной

1ответ

Что делает «offsets.topic.compression.codec» в кафке на самом деле?

Совсем недавно мы начали получать MessageSizeTooLargeException в метаданных, поэтому мы включили offsets.topic.compression.codec = 1, чтобы включить сжатие gzip, но общие байты в скорости/сообщениях п