-
Bug
-
Resolution: Done
-
Major
-
2.6.0.Alpha2
-
None
-
False
-
None
-
False
-
-
Redis tests don't wait for Redis server to start when creating Redis client and thus tests may fail with following exception:
2024-02-26 14:03:01,468 ERROR [io.deb.ser.ConnectorLifecycle] (pool-6-thread-1) Connector completed: success = 'false', message = 'Unable to configure and start the 'io.debezium.server.redis.RedisOffsetBackingStore' offset backing store', error = 'io.debezium.storage.redis.RedisClientConnectionException: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.': io.debezium.storage.redis.RedisClientConnectionException: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream. at io.debezium.storage.redis.RedisConnection.getRedisClient(RedisConnection.java:103) at io.debezium.storage.redis.offset.RedisOffsetBackingStore.connect(RedisOffsetBackingStore.java:52) at io.debezium.storage.redis.offset.RedisOffsetBackingStore.start(RedisOffsetBackingStore.java:71) at io.debezium.embedded.EmbeddedEngine.initializeOffsetStore(EmbeddedEngine.java:552) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:425) at io.debezium.embedded.ConvertingEngineBuilder$1.run(ConvertingEngineBuilder.java:163) at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:173) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642) at java.base/java.lang.Thread.run(Thread.java:1583) Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream. at redis.clients.jedis.util.RedisInputStream.ensureFill(RedisInputStream.java:201) at redis.clients.jedis.util.RedisInputStream.readByte(RedisInputStream.java:42) at redis.clients.jedis.Protocol.process(Protocol.java:126) at redis.clients.jedis.Protocol.read(Protocol.java:192) at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:316) at redis.clients.jedis.Connection.getStatusCodeReply(Connection.java:243) at redis.clients.jedis.Jedis.ping(Jedis.java:354) at io.debezium.storage.redis.RedisConnection.getRedisClient(RedisConnection.java:92) ... 9 more