Я использую Kinesis Stream для чтения событий с использованием библиотеки SpringBoot Stream Reader. Но я получаю выше ошибки во время работы.
@EnableBinding(Sink.class)
public class ActivityProcessorStream {
@StreamListener(Sink.INPUT)
public void handler(String foo)
{
System.out.println(foo);
}
}
Конфигурация - application.yml
spring:
profiles: dev
cloud:
stream:
kinesis:
bindings:
input:
consumer:
shardIteratorType: TRIM_HORIZON
binidings:
input:
destination: "test-stream"
group: stream-app
content-type: text/plain
Конфигурация Pom:
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kinesis</artifactId>
</dependency>
Трассировка стека: org.springframework.context.ApplicationContextException: Не удалось запустить bean-компонент 'inputBindingLifecycle'; вложенное исключение: java .lang.IllegalArgumentException: было запрошено связывание по умолчанию, но в org.springframework.context.support.DefaultLifecycleProcessor.doStart (DefaultLifecycleProcessor. java: 185) ~ связывание недоступно -5.1.8.RELEASE.jar: 5.1.8.RELEASE] at org.springframework.context.support.DefaultLifecycleProcessor.access $ 200 (DefaultLifecycleProcessor. java: 53) ~ [spring-context-5.1.8.RELEASE.jar : 5.1.8.RELEASE] at org.springframework.context.support.DefaultLifecycleProcessor $ LifecycleGroup.start (DefaultLifecycleProcessor. java: 360) ~ [spring-context-5.1.8.RELEASE.jar: 5.1.8.RELEASE] в org.springframework.context.support.DefaultLifecycleProcessor.startBeans (DefaultLifecycleProcessor. java: 158) ~ [spring-context-5.1.8.RELEASE.jar: 5.1.8.RELEASE] в org.springframework.context.support. DefaultLifecycleProcessor.onRefre sh (DefaultLifecycleProcessor. java: 122) ~ [spring-context-5.1.8.RELEASE.jar: 5.1.8.RELEASE] в org.springframework.context.support.Abst ractApplicationContext.finishRefre sh (AbstractApplicationContext. java: 893) ~ [spring-context-5.1.8.RELEASE.jar: 5.1.8.RELEASE] в org.springframework.boot.web.servlet.context.ServletWebServerApplication. finishRefre sh (ServletWebServerApplicationContext. java: 161) ~ [spring-boot-2.1.6.RELEASE.jar: 2.1.6.RELEASE] в org.springframework.context.support.AbstractApplicationContext.refre shxtApp . java: 552) ~ [spring-context-5.1.8.RELEASE.jar: 5.1.8.RELEASE] в org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refre sh (ServletWebServerApplicationConte. 1027 *: 140) ~ [spring-boot-2.1.6.RELEASE.jar: 2.1.6.RELEASE] в org.springframework.boot.SpringApplication.refre sh (SpringApplication. java: 742) ~ [spring -boot-2.1.6.RELEASE.jar: 2.1.6.RELEASE] в org.springframework.boot.SpringApplication.refreshContext (SpringApplication. java: 389) ~ [spring-boot-2.1.6.RELEASE.jar: 2.1.6.RELEASE] в org.springframework.boot.SpringApplication. выполнить (SpringApplication. java: 311) ~ [spring-boot-2.1.6.RELEASE.jar: 2.1.6.RELEASE] в org.springframework.boot.SpringApplication.run (SpringApplication. java: 1213) ~ [spring-boot-2.1.6.RELEASE.jar: 2.1.6.RELEASE] по адресу org.springframework.boot.SpringApplication.run (SpringApplication. java: 1202) ~ [spring-boot-2.1.6.RELEASE. jar: 2.1.6.RELEASE] на com.lionsbot.ruleengineapp.RuleEngineApplication.main (RuleEngineApplication. java: 15) ~ [classes /: na] Причина: java .lang.IllegalArgumentException: связыватель по умолчанию был запрошено, но в org.springframework.util.Assert.notEmpty (Assert. java: 508) нет доступного связующего ~ [spring-core-5.1.8.RELEASE.jar: 5.1.8.RELEASE] в org. springframework.cloud.stream.binder.DefaultBinderFactory.doGetBinder (DefaultBinderFactory. java: 130) ~ [spring-cloud-stream-2.1.0.RELEASE.jar: 2.1.0.RELEASE] в org.springframework.cloud.stream .binder.DefaultBinderFactory.getBinder (DefaultBinderFactory. java: 120) ~ [spring-cloud-stream-2.1.0.RELEASE.jar: 2.1.0.RELEASE] в org.springframework.cloud.stream.binding.BindingService.getBinder (BindingService. java: 313) ~ [spring-cloud-stream-2.1.0.RELEASE.jar: 2.1.0.RELEASE] в org.springframework.cloud .stream.binding.BindingService.bindConsumer (BindingService. java: 94) ~ [spring-cloud-stream-2.1.0.RELEASE.jar: 2.1.0.RELEASE] в org.springframework.cloud.stream.binding. BindableProxyFactory.createAndBindInputs (BindableProxyFactory. java: 234) ~ [spring-cloud-stream-2.1.0.RELEASE.jar: 2.1.0.RELEASE] в org.springframework.cloud.stream.binding. InputBindingLifecycle.doStartWithBindable (InputBindingLifecycle. java: 54) ~ [spring-cloud-stream-2.1.0.RELEASE.jar: 2.1.0.RELEASE] в java .base / java .util.LinkedHashMap $ LinkedValues .forEach (LinkedHashMap. java: 608) ~ [na: na] at org.springframework.cloud.stream.binding.AbstractBindingLifecycle.start (AbstractBindingLifecycle. java: 47) ~ [spring-cloud-stream-2.1. 0.RELEASE.jar: 2.1.0.RELEASE] at org.springframework.cloud.stream.binding.InputBindingLifecycle.start (InputBindingLifecycle. java: 33) ~ [spring-cloud-stream-2.1.0.RELEASE.jar : 2.1.0.RELEASE] at org.springframework.context.support.DefaultLifecycleProcessor.doStart (DefaultLifecycleProcessor. java: 182) ~ [spring-context-5.1.8.RELEASE.jar: 5.1.8.RELEASE] .. 14 общих кадров пропущено
Процесс завершен с кодом выхода 1