kafka-consumer-api

1зной

2ответ

Внедрение фильтрации для сообщений kafka

Недавно я начал использовать Kafka и оценил Kafka для нескольких случаев использования. Если бы мы хотели предоставить возможность фильтровать сообщения для потребителей (подписчиков) на основе содерж

apache-kafka kafka-consumer-api kafka-producer-api 2016-11-02

---

0зной

1ответ

Что происходит, когда болт не может получить кортеж, который он потребляет из определенного потока носика?

Скажем, у меня есть носик, который пропускает сообщения в теме в два потока (stream1 & stream2), и два болта потребляют сообщения из этих потоков (bolt1 -> stream1, bolt2 -> stream2). Теперь, если бол

apache-kafka apache-storm kafka-consumer-api 2016-11-02

---

1зной

2ответ

Initialize createDirectStream с MessageHandler

Ниже существующий код, который я использую для чтения создать Dstream [String] из Кафки Спарк потоковый: var messages: DStream[String] = null val topicsSet = kafkaTopicsName.split(",").toSet message

apache-spark constructor streaming kafka-consumer-api 2016-11-05

---

0зной

1ответ

Проблема в объекте Deserialize protostuff в Кафки Consumer

Получение следующее исключение при десериализации байт [] в объект protostuff в Кафки Consumer java.lang.NegativeArraySizeException at com.dyuproject.protostuff.GraphIOUtil.mergeDelimitedFrom(GraphIO

java apache-kafka kafka-consumer-api kafka-producer-api protostuff 2016-11-11

---

0зной

1ответ

Насколько эффективны сборы Kafka EARLIEST и Kafka LATEST?

Проблема Я думаю о реализации двоичного поиска, чтобы найти начальное смещение для воспроизведения на основе времени событий. Для этого я думал об использовании EARLIEST, чтобы найти начальное смещени

apache-kafka kafka-consumer-api kafka-producer-api kafka-python 2016-11-13

---

0зной

1ответ

reconsume Kafka 0.10.1 тема весна

Весной-Кафкой я хочу пересмотреть тему Кафки с самого начала. Делая это, изменив group.id к чему-то неизвестному до Кафки конечно работает: @KafkaListener(topics = "sensordata.t") public void receive

spring kafka-consumer-api spring-kafka 2016-11-14

---

0зной

1ответ

Спарк Streaming Кафка потребитель не нравится DStream

Я использую Спарк Shell (Scala 2,10 и Спарк Streaming org.apache.spark:spark-streaming-kafka-0-10_2.10:2.0.1), чтобы проверить искру/Кафка потребитель: import org.apache.kafka.clients.consumer.Consume

apache-spark apache-kafka spark-streaming kafka-consumer-api 2016-11-15

---

0зной

1ответ

Интеграция Kafka Storm с java. kafka.api.OffsetRequest.DefaultClientId() Ljava/языки/String; Ошибка

Я новичок в kafka и бурю. Я пытался реализовать Java-пример, который объединяет Кафку и шторм. Я нашел пример в Интернете. Я пытаюсь запустить java-программу в Eclipse IDE. Я не использую maven. У мен

java apache-kafka apache-storm kafka-consumer-api kafka-producer-api 2016-11-16

---