[ISSUE#4530] Add unit test for RedisSourceConnector. #4545
Conversation
Codecov Report
@@ Coverage Diff @@
## master #4545 +/- ##
============================================
+ Coverage 16.14% 16.16% +0.01%
- Complexity 1581 1584 +3
============================================
Files 747 747
Lines 28965 28960 -5
Branches 2541 2539 -2
============================================
+ Hits 4677 4681 +4
+ Misses 23840 23829 -11
- Partials 448 450 +2
... and 15 files with indirect coverage changes 📣 Codecov offers a browser extension for seamless coverage viewing on GitHub. Try it in Chrome or Firefox today! |
| public void setUp() throws Exception { | ||
| connector = new RedisSourceConnector(); | ||
| RedisSourceConfig sourceConfig = (RedisSourceConfig) ConfigUtil.parse(connector.configClass()); | ||
| setupRedisServer(getPortFromUrl(sourceConfig.getConnectorConfig().getServer())); |
There was a problem hiding this comment.
You need shut down the Redis server when the testing is completed.
| RecordPartition partition = new RecordPartition(); | ||
| RecordOffset offset = new RecordOffset(); | ||
| ConnectRecord connectRecord = new ConnectRecord(partition, offset, System.currentTimeMillis(), | ||
| ("\"" + expectedMessage + "\"").getBytes(StandardCharsets.UTF_8)); |
There was a problem hiding this comment.
Is this double quotation mark necessary?
There was a problem hiding this comment.
Yes, if double quotes are not added, an error will occur during redisson deserialization.
* Add unit test for RedisSourceConnector. * Cleanup redisson.
4 participants
Fixes #4530 .
Modifications
Add unit test for RedisSourceConnector.