Я довольно новичок в микросервисах и асинхронных архитектурах, и мне интересно, как типичный запрос...
Я пытаюсь представить метод Java через Scala (от Kafka: https://kafka.apache.org/10/javadoc/index
Когда я создаю соединитель источника или приемника с помощью Confluent Control Center, где он...
Я пытаюсь протестировать и оценить поведение Kafka JDBC Sink Connector, когда база данных не...
Я пытался подключить IBM MQ к Kafka на моем Ubuntu. Я хочу получать сообщения из MQ в Кафку. Я...
Я использую Kafka с Avro для сериализации / десериализации для обработки событий. Если случайно в...
Моё весеннее загрузочное приложение использует Kafka в качестве приложения для моих журналов,...
Использование Kafka в Ubuntu: Зоопарк начал Кафка началась Тема создана Продюсер начал Потребитель...
Что является стандартным (отраслевым стандартом) способом непрерывной работы Java-программы....
Я следовал по этой ссылке для настройки Cassandra Sink с Kafka Connect. В блоге мы сначала...
У меня есть база данных Oracle, содержащая 300 таблиц, и все типы операций DML (вставка /...
Каков будет протокол для клиента, чтобы очень быстро добавлять элементы в Kafka с минимальной...
Я пытаюсь создать поток Kafka в KSQL поверх темы Kafka.У меня есть записи JSON, как показано ниже,...
Я нашел это, где я сбросил свою LAG с помощью инструмента kafka-consumer-groups.sh Как изменить...
В нашей компании мы пытаемся настроить 3node Kafka кластер с SSL-шифрованием и аутентификацией SASL...
У меня есть один steam и таблица в KSQL, как указано ниже: Имя потока: DEAL_STREAM Имя таблицы:...
Я использую следующий блок кода для отправки сообщений Kafka. Нужно ли инициализировать CallBack...
Я пытаюсь построить конвейер на основе этого урока , где Кафка читает из файла с коннектором File...
У меня есть Kafka topic с 1-partition.1 listener определяется в моем приложении для весенней...
Я тестирую пример кода Spring Kafka .Он отлично работает с PLAINTEXT подключением, но не работает с...
Когда я запускаю свой докер-контейнер, я явно предоставляю сеть как host. docker run -d \...
Я развернул Kafka в облаке Google, я изменил слушателей на PLAINTEXT: // [внутренний IP-адрес]:...
Для динамического обновления конфигурации (без перезапуска) на клиенте с Spring Cloud Bus и kafka (...
Получение ошибки ниже как потребитель к теме кафки. Издатель должен использовать сжатие gzip, а...
Я попытался создать этот соединитель из Confluent Control Center, и нажатие кнопки «Продолжить» на...