Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-7564

Wait for Redis server to start

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 2.6.0.Beta1
    • 2.6.0.Alpha2
    • debezium-server
    • 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
      

            vjuranek@redhat.com Vojtech Juranek
            vjuranek@redhat.com Vojtech Juranek
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

              Created:
              Updated:
              Resolved: