Это можно сделать с помощью Kafka 1.1.x. Из документации:

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

это сработало, спасибо, что указал на это :)

Вам просто нужно преобразовать ваш набор данных обратно в фрейм данных с именем столбца «значение», так как kafka требует пары ключ-значение, в которой значение является обязательным полем

 для значений по умолчанию для потребительских свойств.

ли несколько потребителей Kafka читать по умолчанию из одного раздела одной и той же темы? По умолчанию я имею в виду, что group.id не является обязательным....

 позже к желаемым типам.

аюсь использоватьструктурированный потоковый подход использование Spark-Streaming на основе API DataFrame / Dataset для загрузки потока данных из Kafka.Я исп...

, Обратите внимание, что это всего лишь «запрос к потокам» для фиксации как можно скорее - это не выдача фиксации напрямую.

ли способ сделать коммит вручную с Kafka Stream?Обычно с использованием

https://cwiki-test.apache.org/confluence/display/ZOOKEEPER/ZooKeeper+SSL+User+Guide

ользую Kafka версии 0.10.2.0. Есть ли способ обезопасить связь между Zookeper Client, т.е. ZkClient и сервером zookeper с помощью SSL. Я нашел способ сделать...

Имейте в виду, что ваш пользовательский объект должен иметь доступный кодер, иначе Spark SQL откажется помещать свои объекты в набор данных.

ользую Spark2,1.Я пытаюсь читать записи из Kafka, используя Spark Structured Streaming, десериализовать их и впоследствии применять агрегации.У меня есть сле...

@AntoniosChalkiopoulos Спасибо! Я имею это в виду - я просто сначала подумал, что изображения, предоставленные debezium, были настроены заранее, поэтому они лучше работают друг с другом

Кафка: не может создать многопотоковых потребителей

Я только начал работать с Kafka 0.8 beta 1. У меня есть очень простой пример, проблема в том, что я могу заставить работать только одного потребителя сообщений, а не нескольких. То есть метод runSingleWorker () работает. Метод run () НЕ ...