Я пытаюсь понять, как Кафка справляется с ситуацией, когда потребителем выдается несколько ручных...
Случай: для разделения связи репликации клиента и брокера + введение защиты. Вопрос: возможно ли...
Я настроил соединение с базой данных и всю передачу данных по теме, потому что, когда я запускаю...
Может ли кто-нибудь объяснить значение section.duration.ms и flushsize в приведенной ниже...
Моя текущая настройка имеет следующую конфигурацию: @Bean public...
Я пытался продюсера, которого я создал на Java, отправить сообщение в тему о брокере Kafka.Я могу...
У нас есть события, приходящие в Кафку, и с помощью kafka connect мы синхронизируем эти события с...
Если кто-то может выдвигать и использовать одну тему в кластере kafka из 3 брокеров, работающих в...
Код клиента Kafka напрямую ссылается на ip и порт брокера и в случае, если он не работает,...
Я проходил через MongoDB ChangeStream, насколько я понимаю, он снижает риск создания оплога - в...
В моей рабочей среде у меня настроен кластер Kafka с 3 узлами.Я использую ту же настройку Kafka для...
Я немного запутался в том, как настроить, где файлы журнала ошибок записываются для Zookeeper при...
У меня есть следующий json по теме, которую соединитель JDBC публикует в...
Я испытываю новый потоковый API-интерфейс от Flink и пытаюсь запустить мой скрипт с ./flink-1.6
Мой потребитель Kafka должен слушать несколько тем.Каждая тема определяет приоритет, скажем -...
Привет. Я пытаюсь импортировать все таблицы, представленные на удаленном SQL Server, в разделы KSQL
У меня есть несколько микросервисов (пружинная загрузка), и некоторые из них взаимодействуют с...
Может ли кто-нибудь помочь мне написать файлы conf JAAS и классы обработчиков для аутентификации с...
Я начинаю с Akka Streams, и я хотел бы создать сервер как Stream, который получает Http
Я очень новичок в Kafka connect Я вставляю записи из нескольких источников в одну таблицу.В...
Мой кластер kafka имеет 9 узлов. Bcz Я пытаюсь реализовать SSL, в настоящее время я пытаюсь...
Будет ли каждому опубликованному сообщению (при условии, что сообщения сжаты) присвоено уникальное...
Если записи публикуются / отправляются индивидуально в тему Kafka Производителем, будет ли для...
В server.properties У меня есть: zookeeper.connect=node1:2181,node2:2181,node3:2181,node4:2181...
Возможно ли иметь централизованное хранилище / том, который можно разделить между двумя модулями /...