Skip to content

Commit 40d4c60

Browse files
committed
fixed zset test
1 parent 3a135fe commit 40d4c60

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/test/java/com/redislabs/kafkaconnect/RedisEnterpriseSinkTaskIT.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -200,8 +200,9 @@ public void putZset(RedisServer redis) {
200200
List<SinkRecord> records = new ArrayList<>(count);
201201
for (int i = 0; i < count; i++) {
202202
String value = "zsetmember:" + i;
203-
expected.add(ScoredValue.just(i, value));
204-
records.add(SinkRecordHelper.write(topic, new SchemaAndValue(Schema.STRING_SCHEMA, value), new SchemaAndValue(Schema.FLOAT64_SCHEMA, i)));
203+
double score = i;
204+
expected.add(ScoredValue.just(score, value));
205+
records.add(SinkRecordHelper.write(topic, new SchemaAndValue(Schema.STRING_SCHEMA, value), new SchemaAndValue(Schema.FLOAT64_SCHEMA, score)));
205206
}
206207
put(topic, RedisEnterpriseSinkConfig.DataType.ZSET, redis, records);
207208
List<ScoredValue<String>> actual = syncSortedSet(redis).zrangeWithScores(topic, 0, -1);

0 commit comments

Comments
 (0)