kafka-consumer-api

4зной

3ответ

Подсчет Количество сообщений, хранящихся в теме kafka

Я использую версию kafka 0.9.0.0, и я хочу подсчитать количество сообщений в теме kafka без использования сценария администратора kafka-console-consumer.sh. Я пробовал все команды в ответе Java, How t

apache-kafka kafka-consumer-api jms-topic 2017-01-22

---

0зной

1ответ

Pyspark Kafka диапазоны смещения

Я использую Spark в качестве партии для обработки журналов, которые поступают из kafka. В каждом цикле мой код должен получать все, что доходит до потребителя кафки. Тем не менее, я хочу ограничить ко

apache-spark pyspark apache-kafka kafka-consumer-api kafka-python 2017-01-27

---

0зной

1ответ

PipelineDB потребитель от Кафки JSON с массивом

My Кафка отправьте JSON '{ "eventSummaryList": [ { "customer": 1, "data": "{\"cliente\":\"52264\",\"data_posicao\":\"1484250682\",\"gps_valido\":\"1\",\"horimetro\":\"0\",\"ibuttonPa

json kafka-consumer-api pipelinedb 2017-01-28

---

2зной

1ответ

Hbase Table.batch занимает 300 секунд, чтобы вставить 800 000 записей в таблицу

Я читаю json-файл размером 30 мб, обрабатываю для создания семейства столбцов и значений ключей. Затем создайте объект Put, вставьте rowkey и значения в него. Создайте список таких объектов put и вызо

hbase apache-kafka kafka-consumer-api kafka-producer-api hbase-client 2017-01-30

---