Мы создали конвейер приема данных с использованием Kafka. У нас есть потребитель, который читает...

У меня такая ситуация: В микросервисе MS1 есть БД, скажем, с N записями, а внешний источник...

Конфигурация задания потока Kafka и Kafka: Нет раздела: 40 Нет задачи потока: 40 Нет потока потока:...

Мне нужно выполнить несколько операций за одну транзакцию выдать сообщение kafka update Таблица A...

Я создал потоковую топологию, и у меня 1 Source и 2 Sink. Я использую Spring Boot (2.1.9) с Kafka...

Я использую потоковую передачу kafka для объединения потоков, но память вне кучи вышла из-под...

Я использую Spring Cloud Stream с брокером сообщений Kafka в моем Java-приложении. Я использую...

У меня есть приложение Kafka Streams, которое использует тему «А» с 10 разделами и примерно 10 000...

У нас есть приложение Kafka Streams, которое испытывает странное поведение. Случайно, когда задание...

У меня есть приложение Java Kafka, которое использует тему. Иногда встречается ошибка...

Я пытаюсь запустить простой модульный тест с использованием аннотации @EmbeddedKafka. Для справки я...

Я новичок в Kafka / Kafka Stream. Я использую последний Кафка / Кафка-поток и Кафка-клиент и...

При развертывании только с измененной версией Kafka-Streams с 1.1.1 на 2.x.x (без изменения...

Я использую Kafka Docker версию, которая работает нормально (я полагаю?) Из этого репозитория...

Я новичок в Kafka и Spring Cloud и отправляю сообщение с ключом в тему kafka и пытаюсь прочитать...

У меня есть @StreamListener, который принимает строку @Payload.Для тестирования этого класса...

У меня есть тема kafka, которая создается из binlog базы данных MySQL.Он сериализуется в формате...

Я устанавливал службу kafka connect для получения данных от MySQL к kafka брокеру.Просматривая...

Я создаю горизонтальный масштабируемый микросервис Perl без состояния и искал реализацию группы...

У меня был мой исходный разъем debezium mysql, работающий на Kafka.Я добавил еще один исходный...

Я не могу понять, почему мой брокер kafka внезапно остановился / был убит через 2 или 3 активных...

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

Я пытаюсь прочитать полные данные / записи из таблицы ktable, но я заметил, что я могу видеть...

У меня есть ситуация, когда мне нужно дополнить несколько (15) полей дополнительными данными....

Я начинаю с kafka и мне нужно контролировать вставки в конкретную таблицу Oracle, отправлять новые...