2
ответа
Spring Cloud Stream: @StreamListener обрабатывает сообщения дважды
Я использую Spring Cloud Stream (Edgware.SR5) с Spring Boot (1.5.10.RELEASE). Мой @StreamListener обрабатывает дважды каждое полученное сообщение. Идея примера заключается в публикации сообщения в ...
вопрос задан: 15 January 2019 23:02
1
ответ
Есть ли интеграция функции весеннего облака webflux + поток весеннего облака с http источником
Я пытаюсь интегрировать весенний облачный поток с функцией весеннего облака webflux, поскольку в будущих выпусках они устаревают реактивные потоки весеннего облака.
вопрос задан: 27 March 2019 00:49
1
ответ
динамически связывать направления для производителей и потребителей (весна)
Я пытаюсь отправлять и получать сообщения по каналам / темам, чьи имена назначения находятся в базе данных, поэтому их можно добавлять / изменять / удалять во время выполнения, но я удивлен, что нашел немного в Интернете ....
вопрос задан: 17 March 2019 22:06
1
ответ
Spring cloud stream - поддержка перебалансировки потребителей с помощью Kinesis
Поддерживает ли весенний облачный поток Kafka-подобный баланс для кинезиса? Недавно была предпринята попытка решить проблему https://github.com/spring-projects/spring-integration-aws/issues/99. Спасибо
вопрос задан: 5 March 2019 03:57
1
ответ
Spring Cloud Stream против Kafka Stream для функции "Точно однажды"
Я не смог найти здесь и на веб-сайте и в блогах Spring, если Spring Cloud Stream может предоставить семантику «Ровно когда-то», предоставляемую API-интерфейсами Kafka Stream. Может быть, нет ни одной конфигурации / ...
вопрос задан: 4 March 2019 07:54
1
ответ
Весенний поток облака: динамический выходной канал странное поведение
Я использую Spring Cloud Stream версии 2.1.0.RELEASE для отправки сообщений (в данном случае в Kafka) на каналы, динамически определенные на основе полученных входных данных. Проблема в том, что только каждое другое сообщение ...
вопрос задан: 18 January 2019 23:00
1
ответ
Spring Cloud Stream: как переиздать в очередь недоставленных писем, а также выбросить исключение
Я переношу проект, который использует Spring AMQP, в проект, который использует Spring Cloud Stream с RabbitMQ. В моем старом проекте, когда возникла какая-то исключительная ситуация при обработке сообщения с использованием @ ...
вопрос задан: 18 January 2019 21:00
1
ответ
Spring Cloud Stream: свойство spring.cloud.stream.default.consumer.concurrency точно означает
Я хотел бы знать точно значение "параллелизма" при использовании свойства spring.cloud.stream.default.consumer.concurrency. Документация (https: //docs.spring.io/spring-cloud-stream/docs/Chelsea ....
вопрос задан: 18 January 2019 19:47
1
ответ
Невозможно отправить сообщение с KafkaNull в качестве значения
Я создаю приложение Kafka, используя сжатие журналов по теме, но не могу отправить значение Tombstone (KafkaNull). Я попытался использовать конфигурацию по умолчанию для сериализатора и когда это ...
вопрос задан: 18 January 2019 16:14
1
ответ
Запустите MapReduce Jar в облачных данных Spring
Мне нужно запустить весеннее загрузочное приложение mapreduce в облачном потоке данных Spring. Обычно приложения, зарегистрированные в scdf, выполняются с помощью команды "java -jar jar-name". Но моя программа это mapreduce и ...
вопрос задан: 18 January 2019 04:53
1
ответ
Трассировка исключения в заголовке сообщения в очереди недоставленных сообщений
Я использую Spring-Cloud-Stream для получения сообщения от Rabbit MQ. У меня есть очередь и привязка к мертвой букве. Всякий раз, когда возникает какое-либо исключение, сообщения направляются в очередь недоставленных сообщений. ...
вопрос задан: 16 January 2019 10:38
1
ответ
Spring Cloud Stream: очередь недоставленных сообщений по умолчанию для всех привязок
В Spring Cloud Stream вы можете объявить очередь недоставленных писем для привязки «input1» с помощью: spring.cloud.stream.rabbit.bindings.input1.consumer.auto-bind-dlq = true Если у вас есть n привязок, вы должны .. ,
вопрос задан: 15 January 2019 19:56
0
ответов
Пользовательские ключевые последовательности для привязки в Spring Cloud Stream
Я пытаюсь понять, как использовать другой сериализатор / десериализатор ключей в Spring Cloud Stream. Я нашел способ указать глобальные serdes, но я не понимаю, как указать разные serdes ...
вопрос задан: 9 May 2019 09:43