Я использую потребитель kafka в нашем приложении, интегрированном с Camel (Camel-Kafka).Мы...
Я пытаюсь настроить свой проект и попытаться сделать сборку или запустить, но каждый раз, когда...
Загрузка сообщений нашей кафки увеличивается, поэтому мне нужно добавить больше места на диске.Для...
Есть ли способ создания или отслеживания метрик с помощью облачных часов aws для процессов,...
Я хочу докеризировать кластер kafka с двумя экземплярами kafka. под управлением zookeeper docker...
У меня есть kafka KTable, который содержит идентификаторы пользователей.Я называю этот Ktable...
Я пытаюсь масштабировать kafka с помощью docker compose. мой docker-compose.yaml выглядит примерно...
это очень странная проблема, я маскирую метку времени для String, используя TimestampConverter,...
Итак, я переношу старый экземпляр (0.9.0 ... да, я знаю, обновление - это фаза 2) Kafka, и я хочу...
Я новичок в облаке слияния, я хочу настроить SourceConnector для Azur SQL, я не могу понять, как и...
Я пытаюсь подключиться к Kafka с помощью KafkaTool.Я получил ошибку: Ошибка подключения к кластеру
Я новичок в Кафке и микросервисах.Я пытался понять использование свойства id @KafkaClient, но...
Я использую модуль kafka-node для отправки сообщения на kafka.В кластерной среде, где у меня есть...
Как можно указать команду Helm Chart для выполнения одного из контейнеров?Контейнером является...
Я читал о протоколе репликации Kafka.Я обнаружил, что Кафка поддерживает LEO и HW.Как я понял, LEO:...
Попытка запустить тест производительности потребителя в версии Kafka 2.1.0.Команда, которую я...
Я использую Confluent Docker.Я пытаюсь добавить больше брокеров, использующих docker-compose. (я...
Я пытаюсь проверить производительность конфигурации производителя с помощью встроенной команды...
Я только начал изучать Kafka, я не могу понять, зачем нужен ключ в kafka, так как мы также можем...
Я использую kafka-node для подписки на события kafka. const Consumer = kafka.HighLevelConsumer;...
Я настроил поддержку neo4j-stream для автоматической публикации уведомлений для kafka из neo4j
Я реализую своего рода очередь задержек с kafka.Каждое сообщение, полученное контейнером слушателя...
Я хочу включить мониторинг kafka, и я начинаю с развертывания одного узла в качестве теста.Я...
Я использую wurstmeister / kafka-docker , и следую конфигурации swarm в вики kafka-docker.Следуя...
Я просматривал эту статью , которая объясняет, как обеспечить обработку сообщения ровно один раз,...