kafka – список вопросов по тегу – страница №3

Я ищу очередь сообщений для реализации приложения чата. Самое важное требование: когда подписчик указывает критерий фильтрации, все сообщения должны быть отфильтрованы. на...

Есть ли способ включить логическую репликацию wal_level = logical в экземпляре Google Cloud Postgres? Я хочу выполнить CDC (изменение данных) для потоковой передачи записи WAL...

В config doc есть два параметра, связанных с джиттером прокрутки журнала, т.е. log.roll.jitter.ms/log.roll.jitter.hours. Оба они отмечены как важные, но я не знаю, когда их...

Я использую Kafka 0.8.2.1, веду тему с 200 разделами и RF = 3, с сохранением журнала около 1 ГБ. Из-за неизвестного события кластер перешел в состояние «загрузка координатора»...

У меня следующий конвейер: nginx -> unix_socket -> rsyslog -> omkafka module -> kafka...

Мы планируем использовать Kafka для публикации обновлений для наших клиентов. Планируется использовать отдельную тему для каждого клиента. Чтобы упростить им задачу, мы хотим...

У нас есть кластер из трех блоков Kafka + Zookeeper в виртуализированной среде (в Windows 2019 HyperV). В конфигурации машин динамическая память отключена, и у каждой из них...

У меня есть мультиброкер kafka, развернутый на кубернетах, с межброкерской связью SSL, я установил следующие свойства:...

Я хочу, чтобы кафка хранил только последнее значение данного ключа в теме. Это кажется возможным, как показано Вот. Однако единственное, что я до сих пор заархивировал, это то...

Для целей интеграционного тестирования я создаю очень простое развертывание Kafka с одним узлом: 1x Зоопарк 1x Кафка 1x клиент Kafka (например, AdminClient, создание тем)...