kafka-consumer-api

0зной

1ответ

Прочтите сообщения 0.9.0 с помощью KafkaConsumer 0.10.0?

Можно ли читать сообщения от брокера 0.9.0 с KafkaConsumer версии 0.10.0? Чтение документации Я вижу описание того, как обновлять брокеров от 0,9 до 0,10 таким образом, чтобы они продолжали работать с

5зной

1ответ

Возможно ли получить специальное смещение сообщения в Kafka + SparkStreaming?

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

0зной

2ответ

Kafka Раздел раздела

Kafka Тема Позиция смещения раздела всегда начинается с 0 или случайного значения и как обеспечить запись потребителя в первую запись в разделе? Есть ли способ узнать? Если кто-нибудь, пожалуйста, дай

8зной

3ответ

Кафка Java SimpleConsumer странное кодирование

Я пытаюсь использовать SimpleConsumer в Кафки 9, чтобы позволить пользователям воспроизводить события из временного сдвига - но сообщения я получаю назад от Кафки находятся в очень странной кодировке:

1зной

1ответ

Кэширование DStream в Spark Streaming

У меня есть процесс потокового искры, который считывает данные из kafka, в DStream. В моем трубопроводе я два раза (один за другим): DStream.foreachRDD (преобразования по РДУ и вставляя в пункт назнач

4зной

4ответ

Разница в kafka 0.8 с kafka 0.10

Может кто-нибудь указать основные отличительные особенности в Kafka 0,10 по сравнению с kafka 0.8. Мы собираемся модернизировать наш кафка-8 до kafka-10. Какие проблемы можно решить при модернизации?

1зной

1ответ

Kafka Consumer WakeupException Обработка Java

если я запускаю пользователя в потоке kafka, не манипулируя им снаружи, например, чтобы потребитель спал или разбудил его, необходимо правильно обработать WakeupException? И какой хороший подход справ

1зной

3ответ

Kafka: отслеживать задержку для потребителей, назначенных для разделов.

Я работаю с новым API-интерфейсом Kafka 0.9.1. Потребитель вручную назначается разделу. Для этого потребителя я хотел бы видеть его прогресс (что означает отставание). Так как я добавил идентификатор