mindol1004/spring-cloud-stream-binder-kafka
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
904 Commits 15 Branches 87 Tags
main
Commit Graph

904 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Soby Chacko
2e595f34f2 Increase logging in tests 2016-10-18 22:48:55 -04:00
Soby Chacko
acb1c60216 test cleanup 2016-10-18 19:45:44 -04:00
Marius Bogoevici
275f5cbb8e Use Spring Cloud Build as parent 
Fixes #60
 2016-10-17 20:10:06 +05:30
Soby Chacko
79643586dd Ensure that topic is created where broker automatically creates it 2016-10-14 17:31:18 -04:00
Ilayaperumal Gopinathan
b292f81d46 Set producer listener obtained from the context 
- When creating the KafkaMessageChannelBinder set the producer listener that is being autowired in the configuration
 - Add test

This resolves #49
 2016-10-04 19:03:40 +05:30
Marius Bogoevici
8ad98c09b9 Revert to Spring Cloud Stream 1.1.1.BUILD-SNAPSHOT 2016-09-22 15:29:58 -04:00
bamboo
624b039da5 [artifactory-release] Next development version 2016-09-22 01:26:20 +00:00
bamboo
b08888862a [artifactory-release] Release version 1.1.0.RELEASE v1.1.0.RELEASE 2016-09-22 01:26:20 +00:00
Marius Bogoevici
e13e1b1b1b Fix Kafka tests 
As ConsumerProperties are initialized with different defaults
tests must configure them with the same logic as ChannelBindingServiceProperties.
 2016-09-21 20:32:36 -04:00
Marius Bogoevici
513c27beb8 Update to Spring Cloud Stream 1.1.0.RELEASE 2016-09-21 19:01:19 -04:00
Soby Chacko
5f1e6caeab Manual acking tests 
Adding tests to verify manual acking when auto commit
offsets are disabled/enabled.
Docs changes.
 2016-09-21 18:52:27 -04:00
Soby Chacko
ed4416e7c7 Upgrading spring-kafka and spring-integration-kafka dependencies, docs changes 2016-09-21 18:10:46 -04:00
Nadelson, Mark
546fe69346 set Kafka ackMode to MANUAL if autoCommitOffset = false 
polishing
 2016-09-21 18:04:02 -04:00
Marius Bogoevici
30c868e51b Configure JAAS settings for Kafka via Spring Boot 
Fixes #38

Adds support for programmatic configurtion of JAAS
properties as an alternative to using a JAAS file.

Add a placeholder JAAS configuration file which is ignored
by the configuration but lets Kafka 0.9 clients connect
 2016-09-20 11:05:21 -04:00
Marius Bogoevici
6506018a2c Update README.adoc 2016-09-20 09:15:17 -04:00
Marius Bogoevici
09ec23b4bc Minor polishing and refactoring 2016-09-14 15:24:38 -04:00
Soby Chacko
8f4fbd0da6 Making AdminUtils optional 
polishing, docs
Addressing PR review comments
Polishing: Refactoring topic creation methods
Addressing PR comments: Use ClassUtils, Kafka AppInfoParser and polishing
 2016-09-13 17:34:57 -04:00
bamboo
323206130a [artifactory-release] Next development version 2016-09-07 23:38:15 +00:00
bamboo
b944b594b5 [artifactory-release] Release version 1.1.0.RC2 v1.1.0.RC2 2016-09-07 23:38:15 +00:00
Marius Bogoevici
4fa567fec7 Fix documentation issue 2016-09-07 19:14:31 -04:00
bamboo
16d6584774 [artifactory-release] Next development version 2016-09-07 22:38:01 +00:00
bamboo
ea514bd72d [artifactory-release] Release version 1.1.0.RC1 v1.1.0.RC1 2016-09-07 22:38:01 +00:00
Marius Bogoevici
79feac15d0 Upgrade to Spring Cloud Stream 1.1.0.RC1 2016-09-07 18:25:49 -04:00
Marius Bogoevici
3a27a5ec75 Remove redundant spring-kafka declaration 2016-09-07 18:25:22 -04:00
Marius Bogoevici
7308bd4991 Polishing 
Removed optional flag
 2016-09-07 17:53:49 -04:00
Soby Chacko
866eaf4a25 Add support for drop-in support for Kafka 0.10 
Reflectively detect AdminUtils from Kafka 0.9 and 0.10
Introduce Kafka 10 conditionals
 2016-09-07 17:52:53 -04:00
bamboo
b37e7b37d2 [artifactory-release] Next development version 2016-08-26 03:30:26 +00:00
bamboo
a1dd7e4bc9 [artifactory-release] Release version 1.1.0.M1 v1.1.0.M1 2016-08-26 03:30:26 +00:00
Marius Bogoevici
b3f44987b6 Remove 0.8.2-based support classes 
Applications should only use the test support of Spring Kafka
 2016-08-25 23:03:35 -04:00
bamboo
ab8dc84530 [artifactory-release] Next development version 2016-08-26 00:57:03 +00:00
bamboo
55adb34d64 [artifactory-release] Release version 1.1.0.M1 2016-08-26 00:57:03 +00:00
Marius Bogoevici
9539096370 Update versions to milestone/release 
- Spring Cloud Stream 1.1.0.M1
- Spring Kafka 1.0.3.RELEASE
- Spring Integration Kafka 2.0.1.RELEASE
 2016-08-25 20:17:38 -04:00
Marius Bogoevici
96781b65bc Add deserializer to health indicator configuration 
Fixes #17
 2016-08-25 08:25:30 -04:00
Marius Bogoevici
34efddac8d Add recommendations for security 2016-08-24 17:20:57 -04:00
Marius Bogoevici
7849f63f07 Create topic using dedicated AdminUtils call 2016-08-24 09:33:17 -04:00
Marius Bogoevici
73460aa12e Close ProducerFactory on unbind 2016-08-23 16:23:23 -04:00
Marius Bogoevici
1c353da2e1 Add security usage example 
Fixes #25

Addressing PR comments
 2016-08-23 14:33:31 -04:00
Marius Bogoevici
49b75d40cd Change section level 2016-08-22 22:15:24 -04:00
Soby Chacko
fb3f79fd9a Reverting test latency changes 2016-08-22 18:49:20 -04:00
Soby Chacko
c2479b407a increasing the binding latency in the tests temporarily 2016-08-22 18:31:54 -04:00
Marius Bogoevici
3344cf4d38 Fixes for use in kerberized environments 
Fixes #10

Use secured Kerberos ZK client
Add common client properties - security properties don't
have to be repeated
 2016-08-22 17:28:40 -04:00
Marius Bogoevici
fd99944dd2 Documentation edits 2016-08-22 17:11:10 -04:00
Soby Chacko
0252bf2fcd Move Kafka binder docs from Spring Cloud Stream core 
Fixes #4
 2016-08-22 17:10:27 -04:00
Marius Bogoevici
21dbbca8f8 Changes required by the refactoring of AbstractMessageChannelBinder 2016-08-18 12:28:11 -04:00
Marius Bogoevici
2447a16dbe Use Spring Cloud Stream Parent directly 
Since the intent for `spring-cloud-stream-dependencies` to
become the user-facing dependency management BOM, binder
implementations should switch to the Spring Cloud Stream
parent for version management.

This also ensures that they inherit the build lifecycle of
Spring Cloud Stream - e.g. checkstyle validation.
 2016-08-17 14:51:10 -04:00
Marius Bogoevici
a6783a4c64 Remove unneeded RxJava dependencies 2016-07-31 20:52:17 -04:00
Marius Bogoevici
dd505e0366 Add support for specifying generic properties for Kafka producers/consumers 2016-07-31 18:36:48 -04:00
Marius Bogoevici
8f9ac1cd6a Fix POM 2016-07-28 23:48:38 -04:00
Marius Bogoevici
55ea492413 Add back KafkaBinderHealthIndicator 2016-07-28 22:56:15 -04:00
Soby Chacko
1bf14ac390 Upgrade binder to Kafka 0.9 
- Upgrade Spring Integration Kafka from 1.3 to 2.x
- Use Spring Kafka 1.x
- Remove wondowing configuration
- Use the new Spring Kafka and Spring Integration Kafka APIs
 2016-07-28 22:56:02 -04:00