Не могли бы вы помочь мне понять, как поддерживается порядок в журнале коммитов как внутри раздела,...
У меня есть следующий класс модульных тестов, который тестирует Kafka Producer с использованием...
Я пытаюсь использовать слушатель kafka в моем приложении для весенней загрузки, но запуск сервера...
Я настроил 3 узла кафки (версия 2.0.0) и 3 узла кластера zookeeper.И создал одну тему с фактором...
Мне было интересно, как сообщить потребителю kafka, когда при десериализации объекта не удаляется...
У меня было настроено 3 Node Zookeeper и 3 Broker Cluster, когда один из моих брокеров выходит из...
Я хотел бы прочитать все сообщения из темы Кафки в запланированный интервал для вычисления...
Я пытаюсь прочитать сообщение Кафки от производителя, внедрить в него некоторую базовую фильтрацию...
У меня есть кластер kubernetes с тремя узлами в Azure, с тремя брокерами Kafka и одним экземпляром...
Будет ли хорошей идеей использовать архитектуру издателя / подписчика Kafka для службы событий...
Предположим, что есть продюсер, и я запускаю потребителя через несколько минут.Я заметил, что...
Я понимаю, что заказ на раздел гарантирован в Кафке.Но как это повлияет на раздел, если существует...
Как я могу измерить долю производителей и потребителей Kafka в Java-приложении?Предоставляет ли...
Мы работаем над Confluent Platform, и мы все еще знакомимся с внутренними компонентами.Но мы...
Я новичок в Kafka, я внедрил кластер KAFKA на 3 серверах, и на 3 серверах я использую потребителей,...
У меня есть менеджер Cloudera с Кафкой.Kafka настроен для работы с TLS, на стороне приложения у...
Я пытаюсь использовать метку времени режима с mysql, но она не создает никакой темы в моей очереди...
Я использую этот соединитель https://www.confluent.io/connector/sap-hana-connector/ это моя...
Мы серийно потребляем кафку.мы используем X-сообщения, помещаем их в MYSQL, а затем фиксируем их....
Просто хотелось узнать, как определить, сколько каждого тематического раздела в Kafka занимает...
Я использую Kafka в своем Java-приложении. Когда я отправляю сообщение в Kafka для использования...
Я недавно обновился с версии 4.0.1 до версии 5.0.1.Версия bootstrap.server - Kafka 1.0.В моем...
Я сейчас учусь о Kafka Java Java.Среди содержимого о Concumer я часто видел ConsumerRecords.Я хочу...
Мы бы хотели создать механизм повтора кафки для сбоев.Я видел, что многие представили способ иметь...
Я хочу, чтобы несколько пользователей подписались на тему с количеством разделов, равным количеству...