File tree Expand file tree Collapse file tree 3 files changed +15
-1
lines changed
src/main/java/org/sourcelab/storm/spout/redis Expand file tree Collapse file tree 3 files changed +15
-1
lines changed Original file line number Diff line number Diff line change 22The format is based on [ Keep a Changelog] ( http://keepachangelog.com/ )
33and this project adheres to [ Semantic Versioning] ( http://semver.org/ ) .
44
5+ ## 1.1.0 (07/24/2020)
6+ - Add Jedis implementation. Spout defaults to using the Lettuce redis library, but you can configure
7+ to use the Jedis library instead via the ` RedisStreamSpoutConfig.withJedisClientLibrary() ` method.
8+ - Bugfix on Spout deploy, consumer thread started during ` open() ` lifecycle call instead of ` activate() ` .
9+ - Bugfix on Spout restart, resume consuming first from consumers personal pending list.
10+
511## 1.0.0 (07/20/2020)
612- Initial release!
Original file line number Diff line number Diff line change 66
77 <groupId >org.sourcelab.storm.spout</groupId >
88 <artifactId >redis-stream-spout</artifactId >
9- <version >1.0 .0</version >
9+ <version >1.1 .0</version >
1010
1111 <!-- Module Description and Ownership -->
1212 <name >Redis Streams Spout for Apache Storm.</name >
Original file line number Diff line number Diff line change @@ -415,10 +415,18 @@ public Builder withMetricsEnabled(final boolean enabled) {
415415 return this ;
416416 }
417417
418+ /**
419+ * Configure the spout to use the Lettuce client library for communicating with redis.
420+ * @return Builder instance.
421+ */
418422 public Builder withLettuceClientLibrary () {
419423 return withClientType (ClientType .LETTUCE );
420424 }
421425
426+ /**
427+ * Configure the spout to use the Jedis client library for communicating with redis.
428+ * @return Builder instance.
429+ */
422430 public Builder withJedisClientLibrary () {
423431 return withClientType (ClientType .JEDIS );
424432 }
You can’t perform that action at this time.
0 commit comments