Насколько я понимаю, вы можете использовать методы process или transform для определения...
Моя база данных находится в другом узле Linux. Предположим, xxx.xx.xxx.xxx:3306, и я запускаю...
Вариант использования Kafka: непрерывное чтение из Kafka (возможно, из потока), выполнение...
Я хочу непрерывно обрабатывать строки потока набора данных (первоначально инициированные Kafka):...
По умолчанию .windowedBy(SessionWindows.with(Duration.ofSeconds(60)) возвращает запись для каждой...
Пытаюсь подключить кафку с mysql на windows.Я не использую слияния.Моя версия Кафки - 2.12. Я...
Я работаю над конвейером, который читает сообщения от Kafka с использованием KafkaIO, и я смотрю на...
Я новичок в Reactor.Я пытаюсь разработать следующую логику приложения: Чтение сообщений из темы...
Spring-Kafka в Сервере памяти запускается со случайного порта. Таким образом, запись application
Я пытаюсь использовать запись, используя spring-kata, но получаю следующее исключение при запуске...
Я пытаюсь подключить реплицировать таблицу в режиме реального времени с помощью Kafka connect....
Я пытаюсь выслушать тему, на которую я отправил сообщение, используя функцию подключения kafka к...
У меня проблема с использованием соединений kstream.Что я делаю, это из одной темы, я разделяю 3...
Я пытаюсь создать приложение KStream в Eclipse, используя Java. сейчас я имею в виду программу...
Я смотрю учебник по Pipe . Мне нужно нечто подобное, но только местное. Другими словами, код в...
У меня проблема с тем, что мой Kafka ProducerConfig получает недопустимое значение bootstrap
Я пытаюсь создать KTable из KGroupedStream для хранения суммы значения для каждого ключа. final...
Я пробую Кафку Стримс.Написание простого приложения, в котором я считаю дубликаты сообщений....
Поскольку обновление дебезиевого разъема невозможно [DBZ-175] , я пытаюсь создать несколько...
Я использую Kafka Connect в Confluent Community Platform для синхронизации баз данных MySQL
Основная цель - объединить две темы Кафки, одну - сжатые медленно движущиеся данные, а другую -...
У меня есть бесконечный поток (от kafka, использующего реактор-kafka) событий, которые я пытаюсь...
Я использую библиотеку Kafka Node и тестирую высокоуровневого производителя. Я создал тему с 10...
Я пытаюсь использовать kafka-connect-hdfs, но, похоже, это не работает .. Я пытался возиться с...