Вот как инициализируется мой потребитель: const client = new kafka.Client(config.ZK_HOST) const...
Допустим, в Кафке у меня есть 4 раздела темы «А», и у меня есть 20 потребителей группы потребителей...
Я пишу потребительское приложение kafka. У меня есть тема с 4 разделами - 1 лидер и 3 последователи
Я пытаюсь выяснить, нужно ли мне включать фиксацию вручную с помощью KafkaConsumer.commitSync...
Я - Кафка для java-микросервисов с Streams, и мы также используем KeyValueStore для того, чтобы...
Может ли произойти следующая ситуация, когда я создаю получателя и немедленно вызываю consumer
Я хотел бы иметь эффективную систему в реальном времени для выполнения оконных счетчиков событий в...
Есть ли способ приостановить или подавить производителя Kafka на основе отставания потребителей или...
У меня есть тема, которая используется двумя группами потребителей. В теме 10 сообщений. Приложение...
По умолчанию Kafka отправляет сообщения из темы всем группам потребителей. В моем случае у меня...
Мне нужно написать Java-код, чтобы пользователь kafka мог потреблять сообщения. После того, как...
При использовании кафки я хочу получить смещение раздела. Однако, когда я вызываю позицию, я...
Я использую версию kafka 2.0 со scala, некоторые из apis устарели во второй версии. Ниже Это...
Я бы хотел использовать события из темы кафки после времени их прибытия. Время, в которое я хочу,...
У меня есть потребитель Kafka, который подписывается на следующие темы MY_TOPIC,...
У меня есть Kafka Topic (1.0.0) с одним разделом. Потребитель упакован в EAR, и при развертывании в...
Пытается понять потребительскую группу Behavioral в Кафке. Пример 4 разделов доступны. В...
Я только изменил пути к журналам и данным zookeeper в конфигах. Запуск зоопарка:...
Я пытаюсь использовать сообщения в теме кафки, используя команду ниже. Но это не работает....
Я ПИШУ ПОТРЕБИТЕЛЯ КАФКИ Я хочу передать имя темы переменной среды в @kafkalistener (themes = topic...
Я впервые использую Кафку.Я следовал этому учебнику.После запуска Zookeper я запустил сервер kafka
Я немного озадачен ожидаемым поведением poll ().В моем приложении, если processLogic () работает, я...
Я хочу получить данные из сокета и поместить их в тему kafka, чтобы моя программа flink могла...
В случае ошибки интерфейс ConsumerAwareErrorHandler предоставляет ссылку на метод ConsumerRecord и...
Я использовал kafka-python для обработки сообщений в кластере kafka: consumer = KafkaConsumer...