[Bug] Blocked when launching an application using the command 'java -jar app.jar' in the ubuntu server

[tanpenggood]

Current Behavior

In the ubuntu server, when starting the application with the command java -jar app.jar, it is blocked when more than 4 streams / consumer groups are registered.

Funnily enough, I can start normally in the local use IntelliJ IDEA 2023.2 (Community Edition), except OS(Windows 10), other environments are the same with ubuntu server.

Expected Behavior

In the ubuntu server, the application can startup with the command java -jar app.jar, and users can access the Application's rest API.

Steps To Reproduce

1. clone

   git clone https://github.com/tanpenggood-best-practices/spring-boot-redis-stream.git

2. build jar

   mvn clean package

3. run jar, after upload ubuntu server

   java -jar spring-boot-redis-stream-sample.jar

Environment

• Java 1.8

• Maven 3.6

• Redis 5.0.10

• Spring Boot 2.3.4.RELEASE

• Jackson 2.11.2

• Lombok 1.18.12

• Ubuntu Server

   $ uname -a
   Linux t001 4.15.0-1113 #126~16.04.1-Ubuntu SMP Tue Apr 13 16:55:24 UTC 2021 x86_64 x86_64 x86_64 GNU/Linux

Debug logs

Startup log in Ubuntu Server

Blocked during application startup

$ java -jar spring-boot-redis-stream-sample.jar

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v2.3.4.RELEASE)

2023-10-20 15:16:14.813 INFO  [main] o.s.boot.StartupInfoLogger.logStarting(StartupInfoLogger.java:55): Starting Application on CNAZE2CON00102 with PID 18577 (/home/happiness-index-web-server/tp/spring-boot-redis-stream-sample.jar started by happiness-index-web-server in /home/happiness-index-web-server/tp)
2023-10-20 15:16:14.819 INFO  [main] o.s.boot.SpringApplication.logStartupProfileInfo(SpringApplication.java:651): No active profile set, falling back to default profiles: default
2023-10-20 15:16:16.165 INFO  [main] o.s.d.r.c.RepositoryConfigurationDelegate.multipleStoresDetected(RepositoryConfigurationDelegate.java:249): Multiple Spring Data modules found, entering strict repository configuration mode!
2023-10-20 15:16:16.170 INFO  [main] o.s.d.r.c.RepositoryConfigurationDelegate.registerRepositoriesIn(RepositoryConfigurationDelegate.java:127): Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2023-10-20 15:16:16.250 INFO  [main] o.s.d.r.c.RepositoryConfigurationDelegate.registerRepositoriesIn(RepositoryConfigurationDelegate.java:187): Finished Spring Data repository scanning in 49ms. Found 0 Redis repository interfaces.
2023-10-20 15:16:17.192 INFO  [main] o.s.b.w.e.tomcat.TomcatWebServer.initialize(TomcatWebServer.java:108): Tomcat initialized with port(s): 8080 (http)
2023-10-20 15:16:17.212 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Initializing ProtocolHandler ["http-nio-8080"]
2023-10-20 15:16:17.214 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Starting service [Tomcat]
2023-10-20 15:16:17.214 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Starting Servlet engine: [Apache Tomcat/9.0.38]
2023-10-20 15:16:17.321 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Initializing Spring embedded WebApplicationContext
2023-10-20 15:16:17.321 INFO  [main] o.s.b.w.s.c.ServletWebServerApplicationContext.prepareWebApplicationContext(ServletWebServerApplicationContext.java:285): Root WebApplicationContext: initialization completed in 2313 ms
2023-10-20 15:16:18.214 INFO  [main] o.s.s.c.ExecutorConfigurationSupport.initialize(ExecutorConfigurationSupport.java:181): Initializing ExecutorService
2023-10-20 15:16:18.217 INFO  [main] o.s.s.c.ExecutorConfigurationSupport.initialize(ExecutorConfigurationSupport.java:181): Initializing ExecutorService 'redisStreamThreadPoolTaskExecutor'
2023-10-20 15:16:18.711 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test1] success
2023-10-20 15:16:18.726 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test2] success
2023-10-20 15:16:18.731 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test3] success
2023-10-20 15:16:18.737 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test4] success
2023-10-20 15:16:18.742 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test5] success

Startup log in IntelliJ IDEA 2023.2 (Community Edition)

The application can be launched.

  .   ____          _            __ _ _
 /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
 \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  '  |____| .__|_| |_|_| |_\__, | / / / /
 =========|_|==============|___/=/_/_/_/
 :: Spring Boot ::        (v2.3.4.RELEASE)

2023-10-20 16:07:35.394 INFO  [main] o.s.boot.StartupInfoLogger.logStarting(StartupInfoLogger.java:55): Starting Application on CNPC243Z0M with PID 12744 (C:\code\spring-boot-redis-stream\spring-boot-redis-stream-sample\target\classes started by tanpenggood in C:\code\spring-boot-redis-stream)
2023-10-20 16:07:35.399 INFO  [main] o.s.boot.SpringApplication.logStartupProfileInfo(SpringApplication.java:651): No active profile set, falling back to default profiles: default
2023-10-20 16:07:36.286 INFO  [main] o.s.d.r.c.RepositoryConfigurationDelegate.multipleStoresDetected(RepositoryConfigurationDelegate.java:249): Multiple Spring Data modules found, entering strict repository configuration mode!
2023-10-20 16:07:36.291 INFO  [main] o.s.d.r.c.RepositoryConfigurationDelegate.registerRepositoriesIn(RepositoryConfigurationDelegate.java:127): Bootstrapping Spring Data Redis repositories in DEFAULT mode.
2023-10-20 16:07:36.339 INFO  [main] o.s.d.r.c.RepositoryConfigurationDelegate.registerRepositoriesIn(RepositoryConfigurationDelegate.java:187): Finished Spring Data repository scanning in 25ms. Found 0 Redis repository interfaces.
2023-10-20 16:07:37.238 INFO  [main] o.s.b.w.e.tomcat.TomcatWebServer.initialize(TomcatWebServer.java:108): Tomcat initialized with port(s): 8080 (http)
2023-10-20 16:07:37.253 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Initializing ProtocolHandler ["http-nio-8080"]
2023-10-20 16:07:37.254 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Starting service [Tomcat]
2023-10-20 16:07:37.254 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Starting Servlet engine: [Apache Tomcat/9.0.38]
2023-10-20 16:07:37.378 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Initializing Spring embedded WebApplicationContext
2023-10-20 16:07:37.378 INFO  [main] o.s.b.w.s.c.ServletWebServerApplicationContext.prepareWebApplicationContext(ServletWebServerApplicationContext.java:285): Root WebApplicationContext: initialization completed in 1899 ms
2023-10-20 16:07:37.975 INFO  [main] o.s.s.c.ExecutorConfigurationSupport.initialize(ExecutorConfigurationSupport.java:181): Initializing ExecutorService
2023-10-20 16:07:37.978 INFO  [main] o.s.s.c.ExecutorConfigurationSupport.initialize(ExecutorConfigurationSupport.java:181): Initializing ExecutorService 'redisStreamThreadPoolTaskExecutor'
2023-10-20 16:07:39.016 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test1] success
2023-10-20 16:07:39.030 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test2] success
2023-10-20 16:07:39.033 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test3] success
2023-10-20 16:07:39.036 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test4] success
2023-10-20 16:07:39.039 INFO  [main] c.i.b.p.c.RedisStreamConfiguration.registerListener(RedisStreamConfiguration.java:109): init stream [stream_test5] success
2023-10-20 16:07:39.645 INFO  [main] org.apache.juli.logging.DirectJDKLog.log(DirectJDKLog.java:173): Starting ProtocolHandler ["http-nio-8080"]
2023-10-20 16:07:39.703 INFO  [main] o.s.b.w.e.tomcat.TomcatWebServer.start(TomcatWebServer.java:220): Tomcat started on port(s): 8080 (http) with context path ''
2023-10-20 16:07:39.723 INFO  [main] o.s.boot.StartupInfoLogger.logStarted(StartupInfoLogger.java:61): Started Application in 4.916 seconds (JVM running for 5.656)

[mp911de]

Can you please take a thread dump and attach it here? (using jstack).

[jxblum]

First, Spring Boot 2.3.x is out of both OSS support (since May 2021) and commercial support (since August 2022); see here. The same applies for Spring Data Redis 2.3.x, which closely follows Spring Boot's support timelines (see here).

You should upgrade to at least Spring Boot 2.7.17, which will pull in Spring Data Redis 2.7.17. However, keep in mind that Spring Boot / Spring Data Redis 2.7.x are nearly out of OSS support as well, ending in November 2023 (next month). Commercial support extends until August, 2025, but you need a VSR license to get support.

Second, based on your description, you seem to be having environment issues:

"I can start normally in the local use IntelliJ IDEA 2023.2 (Community Edition), except OS(Windows 10), other environments are the same with ubuntu server."

There are any number of reasons why this might happen, and is possibly an environment issue. Though, I might argue that you have race conditions in your configuration/code.

Third, without the Thread dump, it is not really apparent where your application is getting hung up.

Your application "listener" seems reasonably benign.

But, looking at your Spring application configuration, why did you specifically set the initialization (init) and destroy methods of the StreamMessageListenerContainer bean?

The Spring Data Redis StreamMessageListenerContainer is a Spring "SmartLifecycle" bean (Javadoc), so the Spring container itself will handle starting and stopping of the StreamMessageListenerContainer at the appropriate time.

By declaring the bean init/destroy methods, you are prematurely starting the StreamMessageListenerContainer before all other Spring beans declared/defined have had a chance to be properly initialized by the Spring container, such as the TaskExecutor bean. Although, the TaskExecutor bean would seem to be initialized in the intended sequence, starting from here, then here.

Still, a word of caution, if the Spring/Spring Boot setting for proxyBeanMethods is changed from the default (true) to false, then you are going to get into trouble here, as your StreamMessageListenerContainerOptions bean will get a non-managed (i.e. non-bean) instance of the TaskExecutor. It is always better to declare the "dependency" as a bean method parameter, which is equivalent to constructor injection offering initialization safety intrinsic to the nature of the Spring container.

Furthermore, you have once more prematurely initialized the ThreadPoolTaskExecutorBean as well, here. The ThreadPoolTaskExecutor extends ExecutorConfigurationSupport (Javadoc), which declares bean lifecycle handling. In fact, in Spring Framework 6.1, ThreadPoolTaskExecutor will even become a SmartLifecycle bean.

Also, it's not your responsibility to compensate for Spring Boot Actuator. By doing so, you may have shot yourself in the foot.

In any case, there is quite a bit of questionable things going on your configuration/code. Along with the outdated versions and no Thread dump, I don't feel that we should spend any more time debugging your application.

[tanpenggood]

Can you please take a thread dump and attach it here? (using jstack).

Hi @mp911de , Could you please kindly help me analyze it?

2023-10-25 22:41:04
Full thread dump OpenJDK 64-Bit Server VM (25.292-b10 mixed mode):

"logback-4" #26 daemon prio=5 os_prio=0 tid=0x00007f50b8001800 nid=0x5d4f waiting on condition [0x00007f50a9cf9000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000836b0f18> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

"logback-3" #25 daemon prio=5 os_prio=0 tid=0x00007f50b8007800 nid=0x5ce8 waiting on condition [0x00007f50a9dfa000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000836b0f18> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

"Attach Listener" #24 daemon prio=9 os_prio=0 tid=0x00007f50c4001000 nid=0x5ce4 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"lettuce-nioEventLoop-4-2" #23 daemon prio=5 os_prio=0 tid=0x00007f50ac1c7000 nid=0x5c69 runnable [0x00007f50aaffd000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x00000000d8bd0060> (a io.netty.channel.nio.SelectedSelectionKeySet)
	- locked <0x00000000d8bbfdf8> (a java.util.Collections$UnmodifiableSet)
	- locked <0x00000000d8bbfce0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101)
	at io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68)
	at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:805)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

"my-redis-stream-3" #22 prio=5 os_prio=0 tid=0x00007f50f94f6800 nid=0x5c68 waiting on condition [0x00007f50d815e000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000da71bde0> (a java.util.concurrent.CompletableFuture$Signaller)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1709)
	at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1788)
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
	at io.lettuce.core.protocol.AsyncCommand.await(AsyncCommand.java:81)
	at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:117)
	at io.lettuce.core.FutureSyncInvocationHandler.handleInvocation(FutureSyncInvocationHandler.java:75)
	at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:79)
	at com.sun.proxy.$Proxy52.xreadgroup(Unknown Source)
	at org.springframework.data.redis.connection.lettuce.LettuceStreamCommands.xReadGroup(LettuceStreamCommands.java:600)
	at org.springframework.data.redis.connection.DefaultedRedisConnection.xReadGroup(DefaultedRedisConnection.java:591)
	at org.springframework.data.redis.core.DefaultStreamOperations$4.inRedis(DefaultStreamOperations.java:310)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:376)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:371)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:228)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:188)
	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:96)
	at org.springframework.data.redis.core.DefaultStreamOperations.read(DefaultStreamOperations.java:305)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer.lambda$getReadFunction$3(DefaultStreamMessageListenerContainer.java:236)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$548/2125062626.apply(Unknown Source)
	at org.springframework.data.redis.stream.StreamPollTask.doLoop(StreamPollTask.java:138)
	at org.springframework.data.redis.stream.StreamPollTask.run(StreamPollTask.java:123)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

"my-redis-stream-2" #21 prio=5 os_prio=0 tid=0x00007f50f94f5000 nid=0x5c67 waiting on condition [0x00007f50d825f000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000da55ae68> (a java.util.concurrent.CompletableFuture$Signaller)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1709)
	at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1788)
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
	at io.lettuce.core.protocol.AsyncCommand.await(AsyncCommand.java:81)
	at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:117)
	at io.lettuce.core.FutureSyncInvocationHandler.handleInvocation(FutureSyncInvocationHandler.java:75)
	at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:79)
	at com.sun.proxy.$Proxy52.xreadgroup(Unknown Source)
	at org.springframework.data.redis.connection.lettuce.LettuceStreamCommands.xReadGroup(LettuceStreamCommands.java:600)
	at org.springframework.data.redis.connection.DefaultedRedisConnection.xReadGroup(DefaultedRedisConnection.java:591)
	at org.springframework.data.redis.core.DefaultStreamOperations$4.inRedis(DefaultStreamOperations.java:310)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:376)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:371)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:228)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:188)
	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:96)
	at org.springframework.data.redis.core.DefaultStreamOperations.read(DefaultStreamOperations.java:305)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer.lambda$getReadFunction$3(DefaultStreamMessageListenerContainer.java:236)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$548/2125062626.apply(Unknown Source)
	at org.springframework.data.redis.stream.StreamPollTask.doLoop(StreamPollTask.java:138)
	at org.springframework.data.redis.stream.StreamPollTask.run(StreamPollTask.java:123)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

"my-redis-stream-1" #20 prio=5 os_prio=0 tid=0x00007f50f881d000 nid=0x5c66 waiting on condition [0x00007f50d8360000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000da3ab7c8> (a java.util.concurrent.CompletableFuture$Signaller)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1709)
	at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1788)
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
	at io.lettuce.core.protocol.AsyncCommand.await(AsyncCommand.java:81)
	at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:117)
	at io.lettuce.core.FutureSyncInvocationHandler.handleInvocation(FutureSyncInvocationHandler.java:75)
	at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:79)
	at com.sun.proxy.$Proxy52.xreadgroup(Unknown Source)
	at org.springframework.data.redis.connection.lettuce.LettuceStreamCommands.xReadGroup(LettuceStreamCommands.java:600)
	at org.springframework.data.redis.connection.DefaultedRedisConnection.xReadGroup(DefaultedRedisConnection.java:591)
	at org.springframework.data.redis.core.DefaultStreamOperations$4.inRedis(DefaultStreamOperations.java:310)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:376)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:371)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:228)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:188)
	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:96)
	at org.springframework.data.redis.core.DefaultStreamOperations.read(DefaultStreamOperations.java:305)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer.lambda$getReadFunction$3(DefaultStreamMessageListenerContainer.java:236)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$548/2125062626.apply(Unknown Source)
	at org.springframework.data.redis.stream.StreamPollTask.doLoop(StreamPollTask.java:138)
	at org.springframework.data.redis.stream.StreamPollTask.run(StreamPollTask.java:123)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

"lettuce-eventExecutorLoop-1-2" #19 daemon prio=5 os_prio=0 tid=0x00007f50f88aa800 nid=0x5c65 waiting on condition [0x00007f50d8462000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000083e5c058> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
	at io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256)
	at io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

"lettuce-eventExecutorLoop-1-1" #18 daemon prio=5 os_prio=0 tid=0x00007f50f8be6800 nid=0x5c64 waiting on condition [0x00007f50d8563000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000083e5b160> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
	at io.netty.util.concurrent.SingleThreadEventExecutor.takeTask(SingleThreadEventExecutor.java:256)
	at io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:64)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

"lettuce-nioEventLoop-4-1" #17 daemon prio=5 os_prio=0 tid=0x00007f50f8d9d800 nid=0x5c63 runnable [0x00007f50d8864000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x00000000d8ba20d0> (a io.netty.channel.nio.SelectedSelectionKeySet)
	- locked <0x00000000d8b77c48> (a java.util.Collections$UnmodifiableSet)
	- locked <0x00000000d8b76230> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:101)
	at io.netty.channel.nio.SelectedSelectionKeySetSelector.select(SelectedSelectionKeySetSelector.java:68)
	at io.netty.channel.nio.NioEventLoop.select(NioEventLoop.java:805)
	at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:457)
	at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989)
	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
	at java.lang.Thread.run(Thread.java:748)

"container-0" #15 prio=5 os_prio=0 tid=0x00007f50f91b6800 nid=0x5c61 waiting on condition [0x00007f50d8f65000]
   java.lang.Thread.State: TIMED_WAITING (sleeping)
	at java.lang.Thread.sleep(Native Method)
	at org.apache.catalina.core.StandardServer.await(StandardServer.java:570)
	at org.springframework.boot.web.embedded.tomcat.TomcatWebServer$1.run(TomcatWebServer.java:197)

"Catalina-utility-2" #14 prio=1 os_prio=0 tid=0x00007f50f91ac800 nid=0x5c60 waiting on condition [0x00007f50d9066000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000083a48540> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
	at java.lang.Thread.run(Thread.java:748)

"Catalina-utility-1" #13 prio=1 os_prio=0 tid=0x00007f50f91a5800 nid=0x5c5f waiting on condition [0x00007f50d9f67000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000083a48540> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
	at java.lang.Thread.run(Thread.java:748)

"logback-2" #10 daemon prio=5 os_prio=0 tid=0x00007f50f830b800 nid=0x5c5c waiting on condition [0x00007f50da95a000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000836b0f18> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

"Service Thread" #7 daemon prio=9 os_prio=0 tid=0x00007f50f8141000 nid=0x5c59 runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread1" #6 daemon prio=9 os_prio=0 tid=0x00007f50f813e000 nid=0x5c58 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread0" #5 daemon prio=9 os_prio=0 tid=0x00007f50f813b800 nid=0x5c57 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"Signal Dispatcher" #4 daemon prio=9 os_prio=0 tid=0x00007f50f8138800 nid=0x5c56 runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f50f8108000 nid=0x5c55 in Object.wait() [0x00007f50db524000]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x00000000834fdfb0> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144)
	- locked <0x00000000834fdfb0> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165)
	at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216)

"Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f50f8103800 nid=0x5c54 in Object.wait() [0x00007f50db625000]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	- waiting on <0x00000000834fdfe0> (a java.lang.ref.Reference$Lock)
	at java.lang.Object.wait(Object.java:502)
	at java.lang.ref.Reference.tryHandlePending(Reference.java:191)
	- locked <0x00000000834fdfe0> (a java.lang.ref.Reference$Lock)
	at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)

"main" #1 prio=5 os_prio=0 tid=0x00007f50f8008800 nid=0x5c50 waiting on condition [0x00007f50ff9bb000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000d955d6f0> (a java.util.concurrent.CompletableFuture$Signaller)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1709)
	at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1788)
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
	at io.lettuce.core.protocol.AsyncCommand.await(AsyncCommand.java:81)
	at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:117)
	at io.lettuce.core.FutureSyncInvocationHandler.handleInvocation(FutureSyncInvocationHandler.java:75)
	at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:79)
	at com.sun.proxy.$Proxy52.xreadgroup(Unknown Source)
	at org.springframework.data.redis.connection.lettuce.LettuceStreamCommands.xReadGroup(LettuceStreamCommands.java:600)
	at org.springframework.data.redis.connection.DefaultedRedisConnection.xReadGroup(DefaultedRedisConnection.java:591)
	at org.springframework.data.redis.core.DefaultStreamOperations$4.inRedis(DefaultStreamOperations.java:310)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:376)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:371)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:228)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:188)
	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:96)
	at org.springframework.data.redis.core.DefaultStreamOperations.read(DefaultStreamOperations.java:305)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer.lambda$getReadFunction$3(DefaultStreamMessageListenerContainer.java:236)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$548/2125062626.apply(Unknown Source)
	at org.springframework.data.redis.stream.StreamPollTask.doLoop(StreamPollTask.java:138)
	at org.springframework.data.redis.stream.StreamPollTask.run(StreamPollTask.java:123)
	at java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.rejectedExecution(ThreadPoolExecutor.java:2038)
	at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
	at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
	at org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:321)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$555/1029472813.accept(Unknown Source)
	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
	at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
	at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer.start(DefaultStreamMessageListenerContainer.java:158)
	- locked <0x00000000d7877428> (a java.lang.Object)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeCustomInitMethod(AbstractAutowireCapableBeanFactory.java:1920)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1862)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1790)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:594)
	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:516)
	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:324)
	at org.springframework.beans.factory.support.AbstractBeanFactory$$Lambda$146/2059904228.getObject(Unknown Source)
	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:234)
	- locked <0x0000000083747f90> (a java.util.concurrent.ConcurrentHashMap)
	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:322)
	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:202)
	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:897)
	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:879)
	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:551)
	- locked <0x00000000836bbdf8> (a java.lang.Object)
	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:143)
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:758)
	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:750)
	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:397)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:315)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1237)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1226)
	at com.itplh.best.practices.Application.main(Application.java:10)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49)
	at org.springframework.boot.loader.Launcher.launch(Launcher.java:107)
	at org.springframework.boot.loader.Launcher.launch(Launcher.java:58)
	at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:88)

"VM Thread" os_prio=0 tid=0x00007f50f80f9800 nid=0x5c53 runnable 

"GC task thread#0 (ParallelGC)" os_prio=0 tid=0x00007f50f801e000 nid=0x5c51 runnable 

"GC task thread#1 (ParallelGC)" os_prio=0 tid=0x00007f50f801f800 nid=0x5c52 runnable 

"VM Periodic Task Thread" os_prio=0 tid=0x00007f50f8144000 nid=0x5c5a waiting on condition 

JNI global references: 1243

[mp911de]

"main" #1 prio=5 os_prio=0 tid=0x00007f50f8008800 nid=0x5c50 waiting on condition [0x00007f50ff9bb000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000000d955d6f0> (a java.util.concurrent.CompletableFuture$Signaller)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1709)
	at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323)
	at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1788)
	at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
	at io.lettuce.core.protocol.AsyncCommand.await(AsyncCommand.java:81)
	at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:117)
	at io.lettuce.core.FutureSyncInvocationHandler.handleInvocation(FutureSyncInvocationHandler.java:75)
	at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:79)
	at com.sun.proxy.$Proxy52.xreadgroup(Unknown Source)
	at org.springframework.data.redis.connection.lettuce.LettuceStreamCommands.xReadGroup(LettuceStreamCommands.java:600)
	at org.springframework.data.redis.connection.DefaultedRedisConnection.xReadGroup(DefaultedRedisConnection.java:591)
	at org.springframework.data.redis.core.DefaultStreamOperations$4.inRedis(DefaultStreamOperations.java:310)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:376)
	at org.springframework.data.redis.core.DefaultStreamOperations$RecordDeserializingRedisCallback.doInRedis(DefaultStreamOperations.java:371)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:228)
	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:188)
	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:96)
	at org.springframework.data.redis.core.DefaultStreamOperations.read(DefaultStreamOperations.java:305)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer.lambda$getReadFunction$3(DefaultStreamMessageListenerContainer.java:236)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$548/2125062626.apply(Unknown Source)
	at org.springframework.data.redis.stream.StreamPollTask.doLoop(StreamPollTask.java:138)
	at org.springframework.data.redis.stream.StreamPollTask.run(StreamPollTask.java:123)
	at java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy.rejectedExecution(ThreadPoolExecutor.java:2038)
	at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
	at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)
	at org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.execute(ThreadPoolTaskExecutor.java:321)
	at org.springframework.data.redis.stream.DefaultStreamMessageListenerContainer$$Lambda$555/1029472813.accept(Unknown Source)

This stack trace shows that the configured ThreadPoolTaskExecutor is rejecting the Runnable and the configured RejectedExecutionHandler is CallerRunsPolicy. That being said, the Runnable is being invoked on the caller thread and that is what blocks your application.

You have to revisit your ThreadPoolTaskExecutor configuration.

[tanpenggood]

Thank you very much for your guidance.

We found that ubuntu's server is 2 cores, so the core pool size is 3 in ThreadPoolTaskExecutor.
Due to a large number of initialization actions during application startup, the threads in the thread pool are instantly consumed.
And the RejectedExecutionHandler is CallerRunsPolicy, have some accept actions are handed over to the main thread,
causing the application to enter blocked state at startup.

Now, we have adjusted the relevant parameters of the thread pool, the application can start and run normally.

Increasing the queue capacity to 100, etc.

@Bean("redisStreamThreadPoolTaskExecutor")
public ThreadPoolTaskExecutor redisStreamThreadPoolTaskExecutor() {
    int coreSize = Runtime.getRuntime().availableProcessors() + 1;
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(coreSize);
    taskExecutor.setMaxPoolSize(coreSize);
    taskExecutor.setQueueCapacity(100);
    taskExecutor.setThreadNamePrefix("my-redis-stream-");
    taskExecutor.setRejectedExecutionHandler((r, executor) -> log.error("RejectedExecutionHandler: runnable={} executor={}", r, executor));
    // If not initialized, the actuator cannot be found
    taskExecutor.initialize();
    return taskExecutor;
}

Thank you again for your help~