-
Bug
-
Resolution: Done
-
Major
-
2.6.0.Alpha2
-
None
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