spring-cloud-stream

4зной

1ответ

Весенний облачный поток с реактивными потоками

Моя цель - сделать приложение с использованием Spring cloud stream и Kafka и открыть «реактивный» мир. У меня что-то работает. Вот часть моего потребителя. В моем П, я объявил: <dependency> <g

2зной

1ответ

как отправить и получить от той же темы в пределах весеннего облачного потока и kafka

У меня есть приложение spring-cloud-stream с привязкой к кафке. Я хотел бы отправить и получить сообщение из той же темы из одного и того же исполняемого файла (jar). У меня есть определения моего кан

0зной

1ответ

Непризнанный токен 'Ã¿': ожидал ('true', 'false' или 'null')

Я пытаюсь отправить сообщение Кафке и использовать то же сообщение от Kafka, используя Spring cloud stream. Я отправляю JSON String {"acctNo": "32432", "tn": "3234"}, используя Postman для остального

1зной

1ответ

Spring Cloud Stream Kafka binder compression

Как включить сжатие (например, GZIP) для производителей с использованием Spring Cloud Stream Kafka Binder?

0зной

1ответ

o.apache.kafka.common.network.Selector: Ошибка ввода-вывода с localhost/127.0.0.1

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

2зной

1ответ

как вызвать скрипт python из микросервиса на основе stream-cloud-stream

Я думаю использовать Spring-cloud-stream для создания приложения для микросервиса, управляемого сообщениями, с помощью RabbitMQ в качестве брокера. Я вижу, что spring-cloud-stream построен на основе S

1зной

1ответ

Руководство Подтверждение сообщений: Spring Cloud Stream Kafka

Сценарий, который я хочу реализовать, - это сообщение от Kafka, обрабатывающее его, если какое-то условие не работает, я не хочу признавать сообщение. Для этого я нашел в справочной документации по по

0зной

1ответ

Нет подходящего компонента типа [com.comcast.activation.message.interfaces.MessageChannels], найденного для зависимости:

У меня есть приложение загрузки весны, которое просто отправляет сообщения в тему kafka. Код выглядит так. @RestController @RequestMapping("/ActivationQueueService") public class ActivationQueueCont

2зной

3ответ

Турбина может найти только один хост при использовании докер

У меня есть 3 проектов: а Hystrix приборной панели, сервер турбины (с использованием AMQP) и API При запуске в окр развития, я создал 2 экземпляров API (с использованием портов 8080 и 8081). Чтобы про