Spring Cloud Stream AWS Kinesis Binder: Difference between revisions
Jump to navigation
Jump to search
| Line 38: | Line 38: | ||
String payload = "..." | String payload = "..." | ||
Message m = new GenericMessage<>(payload); | Message m = new GenericMessage<>(payload); | ||
outputChannel.send(m); | |||
</syntaxhighlight> | </syntaxhighlight> | ||
| Line 49: | Line 49: | ||
} | } | ||
</syntaxhighlight> | </syntaxhighlight> | ||
==Headers== | ==Headers== | ||
Revision as of 19:49, 18 December 2018
External
- Binder Implementation GitHub https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis
- AWS Kinesis Binder Reference Manual https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis/blob/master/spring-cloud-stream-binder-kinesis-docs/src/main/asciidoc/overview.adoc
- Example GitHub https://github.com/spring-cloud/spring-cloud-stream-samples/tree/master/kinesis-samples
Internal
Overview
Dependencies
dependencies {
implementation('org.springframework.cloud:spring-cloud-stream-binder-kinesis:1.0.0.RELEASE')
}
Playground Examples
Message Propagation
Payload
The payload passed to the message as follows:
MessageChannel outputChannel = ...;
String payload = "..."
Message m = new GenericMessage<>(payload);
outputChannel.send(m);
is recovered at the other end as follows:
@StreamListener(InputChannelFactory.INPUT_CHANNEL_NAME)
public void handle(Message<String> e) {
String payload = e.getPayload();
}
Headers
Consumer Group Support
Also see:
Configuration
Stream Auto-Creation
1.0.0 cannot be configured to fail on inexistent stream, instead of creating it. See org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisStreamProvisioner line 135.
Also see