SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
532 Commits 28 Branches 0 Tags
9a65728cc676d72d0944ceff0a85ebd2098e76d6
Commit Graph

532 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Dave Syer
9a65728cc6 Migrate to mvn 3.3.9 2016-06-04 09:14:54 +01:00
Ilayaperumal Gopinathan
9207811214 Fix mainApplicationClass for child contexts 
- Make sure to set the appropriate mainApplicationClass name for the child applications

This resolves #562
 2016-06-03 21:20:14 +05:30
Marius Bogoevici
0076c7b9f5 Update to Spring Integration Kafka 1.3.1.RELEASE 2016-06-02 16:45:40 -04:00
Mark Fisher
4d8ced734b polishing 2016-06-02 13:36:05 -04:00
Marius Bogoevici
6eddac9056 Allow binders to not affect the defaulting process 
Fixes #557

Allow for a `defaultCandidate` flag on a binder configuration that, when FALSE,
ensures that the binder does not interfere with the default configuration process.
 2016-06-02 13:22:14 -04:00
Marius Bogoevici
53d86f5523 Simplify marshalling of JSON messages 
Fixes #558
 2016-06-02 18:33:16 +05:30
Marius Bogoevici
99db7dff9b GH-541 Make reconnect time for Kafka/Rabbit configurable 2016-06-01 14:12:26 -04:00
Marius Bogoevici
aef08a28a3 Move tests to AssertJ 2016-06-01 13:10:42 -04:00
Eric Bottard
fbe9bbac7e Fix doc source formatting 2016-06-01 15:40:09 +02:00
Marius Bogoevici
1f3661f4c4 Fix race condition in testDefaultAutoCommitOnErrorWithDlq 2016-05-29 08:51:28 -04:00
Marius Bogoevici
e2f91417c3 Add setting for autoCommitOnError 
Fixes #542

- add option for `autoCommitOnError`
- make `autoCommitOnError` follow the state of `enableDlq` - no need to suppress commits if messages will be sent elsewhere
 2016-05-28 11:08:31 -04:00
Ilayaperumal Gopinathan
892797c0b0 Clarify channel names in the doc 
Fixes #551
 2016-05-26 11:53:12 -04:00
Marius Bogoevici
51a451300a Use KafkaBinderConfigurationProperties directly 
Fixes #548

- Remove redundant property copying
- Make `socketBufferSize` configurable (it wasn't provided as a configuration option)
 2016-05-25 17:59:19 -04:00
Marius Bogoevici
1d0031d356 Use CustomizableThreadFactory for Kafka Binder 
Fixes #543

We don't need another ThreadFactory implementation and can use Spring Framework class instead.
 2016-05-17 15:03:46 -04:00
Ilayaperumal Gopinathan
48d2888b71 Fix retry consumer properties for Kafka 
- Remove `ignored by Kafka` for the retry properties
 2016-05-16 16:41:48 +05:30
Ilayaperumal Gopinathan
bcc45b8685 Use random port in StreamListenerTests 2016-05-13 11:44:35 +05:30
Ilayaperumal Gopinathan
33500ae183 Use random server port in ModuleAggregation tests 2016-05-13 11:44:28 +05:30
Marius Bogoevici
18dc0a707d Implement remainder of Spring Boot Checkstyle code rules 
Fixes #532

Implements most of the remaining rules from Spring Boot, except JavaDoc + a few additional ones
 2016-05-12 19:19:59 -04:00
Marius Bogoevici
bbe5b3ee56 Fix Travis build target 2016-05-12 15:57:07 -04:00
Marius Bogoevici
91958ce53d Travis updates 
- Remove use of .settings.xml in favour of Spring profile
- Use external Kafka broker
 2016-05-12 15:27:06 -04:00
Dave Syer
49e20d38c2 Re-instate .settings.xml for Travis 2016-05-12 11:34:46 +01:00
Dave Syer
bdea2c7a37 Update README and remove .settings.xml where appropriate 2016-05-12 10:47:36 +01:00
Marius Bogoevici
a974ff7773 Checkstyle rules for imports and cleanup 
Fixes #529

- enforced Spring Framework ordering rules
- disallowed static imports except for specific classes in test frameworks
 2016-05-11 22:13:18 -04:00
Marius Bogoevici
8274d48cad Upgrade to Spring Boot 1.4.0.BUILD-SNAPSHOT 2016-05-11 16:23:18 -04:00
Marius Bogoevici
296d710969 Update project version to 1.1.0.BUILD-SNAPSHOT 2016-05-10 19:41:15 -04:00
bamboo
e211a6340d [artifactory-release] Next development version 2016-05-10 13:33:46 +00:00
bamboo
53f1839a82 [artifactory-release] Release version 1.0.0.RELEASE 2016-05-10 13:33:46 +00:00
Marius Bogoevici
b579ddbcc5 Restore the option to run Kafka tests embedded vs. external 
Honour the `SCS_KAFKA_TEST_EMBEDDED` flag when set as an environment variable
or Java property: when explicitly set to `false`, use an external broker and observe the
`SCS_EXTERNAL_SERVERS_REQUIRED` property (i.e. fail if server is missing). By default,
continue to run tests using an embedded broker.
 2016-05-10 09:12:34 -04:00
Marius Bogoevici
9668cb968f Upgrade to Spring Cloud Build 1.1.1.RELEASE 2016-05-10 08:38:56 -04:00
Ilayaperumal Gopinathan
6bc5c8c1c1 Upgrade RxJava to 1.1.5 
This resolves #552
 2016-05-10 16:39:31 +05:30
Ilayaperumal Gopinathan
de7d71255b Add doc for multiple destination names when binding consumer 2016-05-09 16:03:43 -04:00
Marius Bogoevici
a86d47315b Upgrade to Spring Cloud Build 1.1.1.BUILD-SNAPSHOT 
- removed redundant overrides
- added explicit version for maven-antrun-plugin (not inherited from Spring Boot Parent anymore)
 2016-05-09 15:58:58 -04:00
Ilayaperumal Gopinathan
af31dbeeeb Doc cleanup 2016-05-09 14:31:53 +05:30
Marius Bogoevici
cc639d2855 Add documentation for Binder SPI 
Fixes #476 #278
 2016-05-09 11:30:26 +05:30
Marius Bogoevici
678ed0387f Add documentation for content type and transformation 
Fixes #421

- Porting and adjusting the applicable Spring XD documentation
- Adding StreamListener section
 2016-05-09 11:14:39 +05:30
Marius Bogoevici
34885ed975 Revert Spring Cloud Commons upgrade until a fix for docs is available 2016-05-08 20:18:10 -04:00
Marius Bogoevici
4c35c7ff59 Use Spring Cloud Commons 1.0.0.RELEASE 
- Remove outdated `spring-core` and `spring-integration` overrides
 2016-05-08 19:18:33 -04:00
Marius Bogoevici
eb119117db Cleanup of spring-cloud-stream-dependencies 
- removed obsolete dependency management for `spring-cloud-stream-common`
and `spring-cloud-stream-module-test-support`
 2016-05-08 18:59:34 -04:00
Marius Bogoevici
7f5bea3522 Use Spring Tuple 1.0.0.RELEASE 2016-05-08 18:46:10 -04:00
Dave Syer
9a749e10d7 Add explicit release disabled flag for artifactory for plugins 2016-05-06 18:09:41 +01:00
Dave Syer
a0efd4c137 Add explicit release disabled flag for artifactory in dependencies 2016-05-06 17:59:47 +01:00
Matt Benson
9119e794c8 simplify KafkaMessageChannelBinder ctor call 2016-05-06 12:51:23 -04:00
Dave Syer
216d5a1ac6 Add explicit release disabled flag for artifactory 2016-05-06 17:47:14 +01:00
Ilayaperumal Gopinathan
ee41e802d7 Update consumer properties in the doc 2016-05-06 21:29:38 +05:30
Vinicius Carvalho
7044795fe4 Fixing partition section where 'producer' key was missing from example' 2016-05-06 10:13:42 -04:00
Matt Benson
5b05637cd4 add missing accessors for configuration properties' array members 2016-05-05 10:16:43 -05:00
Marius Bogoevici
02ee8d4d88 GH-509: Rework Topic Autoconfiguration 
Fixes #509

- prevent autoconfiguration from reducing the existing partition count and/or replication factor

Split `autoConfigureTopics` in two separate settings, one for `autoCreateTopics`
and one for `autoAddPartitions` (to existing topics)

Renamed `defaultMinPartitionCount` to just `minPartitionCount` on the Kafka binder
 2016-05-04 15:32:11 -04:00
Marius Bogoevici
8d5bf66c7f GH-504: AutoConfiguration of Kafka Topics 
Add a flag for controlling topic autoconfiguration by the Kafka binder

Fixes #504

- introduces a new binder setting `autoConfigureTopics` that allows the user to disable the automatic creation of topics by the binder

Additional tests for partitioning

Adding missing documentation for `replicationFactor`
 2016-05-03 10:08:16 -04:00
Ilayaperumal Gopinathan
2c40db0cd8 Minor updates 2016-05-03 15:15:24 +05:30
Marius Bogoevici
39cf1e272d Documentation for RxJava and Aggregates 2016-05-03 15:08:34 +05:30