Итак, у меня есть случай использования, когда у меня есть соединитель kafka, который использует...
Я создаю тему кафки следующим образом: kafka-topics --create --zookeeper xx.xxx.xx:2181...
Используя разъём debezium mongo, я отправляю данные из mongodb в kafka. У меня есть 4 коллекции:...
Я использую kafka_2.11-2.1.1 и Производитель использует пружину 2.1.0.RELEASE. Я использую Spring,...
Получение этой ошибки во время работы zookeeper. Я скачал zookeeper с официального сайта и...
У нас странное поведение в нашем кластере Kafka Когда мы запускаем описанную информацию как...
Флинк работает над кафкой для разных скоплений.Один из потоков, который мы анализируем, это...
Нужна помощь по следующей проблеме: выход из памяти при загрузке из таблицы PostgreSQL с 13...
У меня есть две схемы, скажем, A и B. B зависит от A. Например, A является { "namespace":...
Я нуб в Apache Kafka.Я читаю книгу Краткое руководство по Apache Kafka и следую инструкциям по...
Резюме Когда я транслирую это с производителем консоли {"id":1337...
Я использую это debezium-examples docker-compose -f docker-compose-jdbc.yaml up все работает...
У меня есть набор микросервисов, взаимодействующих через события на Кафке. Иногда случается, что у...
Сколько запросов метаданных сделает производитель Kafka? по одному на сообщение, по одному на пакет...
Обучение использованию Flink (1.8.0) с Python, попытка прочитать тему Кафки. Использование кода из...
Я бы хотел настроить кластер Kafka, чтобы разрешать только большие сообщения по определенной теме....
Мы используем консул для распространения конфигурации и обнаружения службы вручную (используется...
Я начал Sink JDBC несколько недель назад. Все было хорошо, пока в логах не появилась эта ошибка:...
Я пишу Java API для создания потребителя Kafka У меня есть ошибка: Exception in thread...
У меня есть ServiceA, который создает DomainChangeEvents и фиксирует их в теме в kafka, затем...
Я хочу создать Kafka Connector, чтобы получать записи из базы данных практически в реальном времени
t Найдено несколько ресурсов defaults.yaml.Вы, вероятно, связываете банки Storm со своей...
При настройке службы заказа кафки все узлы заказа будут иметь одинаковые блоки транзакций.Поскольку...
В настоящее время я реализовал приемник kafka, который работает следующим образом: Внутри цикла...
, когда медленная потребительская ситуация и размер сообщения превышают log.retention.bytes или log