Я думаю о шаблоне архитектуры, когда у каждого клиента моего сервиса есть собственный потребитель...

Так что я использую контекст React, потому что я должен изменить состояние в противоположном...

Мы используем activemq для брокера сообщений микро-сервисов.Мой запрос о том, как построить...

Я пытаюсь создать подписчика в моем приложении Spring Boot.Моя цель состоит в том, чтобы издатель...

Я пытаюсь реализовать решение RabbitMQ в среде, в которой все соединения должны быть запущены из...

Краткое объяснение Итак, я хочу добиться следующего: после подтверждения того, что адрес...

У меня есть служба Springboot с методом POST и принимает данные JSON. я могу создать файл pact для...

Мне нужно принимать сообщения JMS с Camel каждый день в 21:00 (или с 9:00 до 22:00, чтобы дать ему...

Как я понимаю, Kafka, идентификатор группы потребителей и THAT ALONE определяют, принадлежат ли N>...

Если у нас есть переменная AsyncResponse response, мы можем написать что-то вроде:...

Я играл с Spring Cloud Contracts.Вот мое понимание рабочего процесса до сих пор. На стороне сервера...

Я кодирую решение для потребителя данных в кластер kafka (используя докеры для kafka), но мне все...

Ищите, как использовать лямбда-функции Java, чтобы Потребитель мог обрабатывать все объекты,...

Мой потребительский процесс умер при удалении темы.Но программа просто заблокирована и выводит логи...

Я довольно новичок в написании Java, и в настоящее время я пытаюсь реализовать другой аспект...

Есть ли способ сгенерировать PACT-файл для передачи проверки формата данных? Пример того, чего я...

Этот скрипт - метод подписки на событие от Kafka. using Confluent.Kafka; using Confluent.Kafka

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

Я пытаюсь вернуть логическое значение внутри метода, и я использую функцию потребителя.Есть ли...

У меня есть менеджер Cloudera с Кафкой.Kafka настроен для работы с TLS, на стороне приложения у...

Учитывая следующий код: public void doSomething(Channel channel1){ DefaultConsumer consumer1 = new...

Я пытаюсь определить общий абстрактный класс, который обрабатывает логику обработки / повторения...

Используя kombu для моего потребителя кролика, я часто нахожу мертвых потребителей в очереди, для...

Я в настоящее время реализую работу потребителя.Я хочу получить доступ к объекту распознавателя...

Я пытаюсь использовать mirror maker для репликации темы __consumre_offsets вместе с другими темами....