SpringCloud/spring-cloud-stream-binder-aws-kinesis

Files

Peter.Oates 22f95aa1e6 Initial implementation for AWS Kinesis Binder

Fixes spring-cloud/spring-cloud-stream-starters#9

Basic code to implement Kinesis binder, based on code from Kafka binder.

Update to PR 1 based on review by artembilan

Added gitignore for IDEA files
Added Maven wrapper

pom.xml:
Updated project version to match three digit style
Updated spring-cloud-build to 1.3.3.BUILD-SNAPSHOT
Updated spring-cloud-stream to 1.3.0.BUILD-SNAPSHOT
Uncommented checkstyle

KinesisStreamProvisioner:
Renamed KinesisTopicProvisioner to KinesisStreamProvisioner
Replaced Logging with commons logging
Added check for logging enabled to log output
Renamed arguments to streamName and shards
Qualified properties with this.

spring-cloud-stream-binder-kinesis-core/pom.xml:
Added aws-java-sdk-kinesis dependency

spring-cloud-stream-binder-kinesis/pom.xml:
Removed dependencies provided transitively from core
Replaced spaces with tab indents in XML files
Removed unused plugin

KinesisBinderEnvironmentPostProcessor:
Removed copied properties configuration

KinesisBinderConfiguration:
Removed redundant annotations
Removed redundant logger

KinesisMessageChannelBinder:
Removed redundant setOutputChannel

* Some polishing and reformatting

2017-06-01 18:39:59 -04:00

147 B

Raw Blame History

Spring Cloud Stream Binder for AWS Kinesis

This repository contains the code for the Spring Cloud Stream Binder implementation for AWS Kinesis.

147 B Raw Blame History

Spring Cloud Stream Binder for AWS Kinesis

147 B

Raw Blame History