Результаты поиска по запросу "apache-kafka"
Как вручную зафиксировать смещение в прямой трансляции Spark Kafka?
Я внимательно посмотрел вокруг, но не нашел удовлетворительного ответа на это. Может быть, я что-то упустил. Пожалуйста помоги.У нас есть потоковое приложени...
Как истекает смещение для группы потребителей Apache Kafka?
Я делал несколько тестов на старую тему, когда заметил странное поведение. Читая журнал Кафки, я заметил это сообщение «удалено 8 истекших смещений»:
Распечатать Кафка Стрим Вводить на консоль?
Я просматривал много документации Kafka для Java-приложения, над которым я работаю. Я попытался войти в лямбда-синтаксис, представленный в Java 8, но я немно...
Исключение при доступе к KafkaOffset из RDD
У меня есть потребитель Spark, который течет из Кафки. Я пытаюсь управлять смещениями для семантики, выполняемой ровно один раз.Однако при доступе к смещению...
Кафка многораздельного заказа
Мне известно, что в Kafka невозможно заказать несколько разделов и что порядок разделов гарантирован только для одного потребителя в группе (для одного разде...