На данный момент я тестирую использование Spring Integration, чтобы связать вместе разрозненные модули в одном приложении Spring-Boot и службы в единый поток, начиная с единой точки входа. Если возможно, я ищу следующие пояснения по поводу Spring...

У меня есть требование загрузить файл с S3 на основе содержимого сообщения. Другими словами, файл для загрузки ранее неизвестен, я должен искать и находить его во время выполнения. S3StreamingMessageSource не подходит, потому что: Это зависит...

У меня проблема, аналогичная упомянутой >здесь . Я использую конфигурации spring xml. У меня указаны учетные данные глобального контекста AWS. Я использую адаптер исходящего канала S3 для загрузки файла с S3. Мои ключи указаны в файле...

Я пытаюсь запустить этого простого потребителя сообщений кинезиса с помощью следующего кода. Это единственный класс в приложении Я столкнулся с этой ошибкой, так как я обновил последнюю версию снимка программы kinesis binder....

Я пытался реализовать балансировку нагрузки для потребителей потока Aws kinesis Согласно документации я пытаюсь реализовать spring: cloud: stream: instanceIndex: 1 instanceCount: 3 bindings: RollUpInboundStream:...

Я отправляю 100 сообщений в поток с 1 шрадом. spring: cloud: stream: bindings: myOutBound: destination: my-stream contentType: application/json Я помещаю сообщения в цикл для целей тестирования...

Я зарегистрировал AsyncHandler , а также добавил success-channel в исходящий поток SQS. success-channel имеет конечную точку int:logging-channel-adapter . Однако я не могу видеть журналы с этого адаптера. AsyncHandler может получать...

Как настроить реактивный поток с помощью DSL для следующих шагов: Получите сообщение SQS, используя SqsMessageDrivenChannelAdapter Проверьте сообщение Json [ JsonSchemaValidator класс с validate методом] Преобразуйте json в объекты...