Я создаю приложение для электронной коммерции, в котором в настоящее время я работаю с двумя...
Я создал материализованное представление в потоке kafka, я не могу найти фрагмент кода Java для...
Мы используем Kafka 0.10 со Spark 2.1, и я обнаружил, что публикация нашего производителя всегда...
Я играю с Kafka Streams и столкнулся с ситуацией, которая кажется мне немного странной. Я искал по...
Можно ли определить serialVersionUID в классе, который расширяет интерфейс Serializer /...
в конфигурации коннектора исходного кода Kafka Connect У меня есть "_comment":...
Мы недавно обновили нашу версию kafka с 0.10 до 1.0, и я обновляю устаревший код KTable<Long,...
Какой класс / метод в Kafka Streams мы можем использовать для сериализации / десериализации...
У меня есть простой конвейер потока данных (код задания 2018-05-15_06_17_40-8591349846083543299) с...
Я пытаюсь провести простой тест, в котором я использую Kafka-connect и spark Я написал...
Кто-нибудь интегрировал iOS-устройства в качестве производителя для kafka? Есть ли какие-либо...
Нужна помощь, пожалуйста. Я использую IntelliJ с SBT для сборки своих приложений. Я работаю над...
Я использую Spring Cloud Stream 1.3.2.RELEASE , чтобы опубликовать строковое сообщение для Кафки....
Когда я говорю, что это встроено, я имею в виду следующую тему: https://stackoverflow
Я использую Java сервлет. В файле web.xml я инициализировал кварцевый планировщик. У меня есть 2...
Я работаю над ручным управлением смещением в Кафке, используя spark-streaming-kafka-0-8_2.11 org
Я новичок в kafka connect, пытаюсь построить конвейер для передачи данных из sqlite в тему kafka.
Определен пользовательский магазин, для использования в пользовательском Transformer (ссылка ниже)....
Я пытаюсь развернуть несколько зоопарков (каждый в своем собственном контейнере) с помощью Docker...
У меня есть Processor-API Processor, который внутренне перенаправляет в несколько отдельных...
Мое требование У меня есть файлы журналов, которые мне нужно обработать, а также я хотел бы...
Данные, получаемые из потока, должны агрегироваться на дневном и месячном уровне. С учетом...
Могу ли я использовать преобразование без состояния, даже если это означает изменение ключа на...
Если мы запустим приложение KafkaStream в фоновом режиме (скажем, в Linux), есть ли способ передать...
Я хотел бы знать, какой будет правильный способ включения backpressure в spark streaming через...