192.168.121.135:6379> del stream-001
(integer) 1
192.168.121.135:6379> XGROUP CREATE stream-001 group-a $ mkstream
OK
192.168.121.135:6379> XGROUP CREATE stream-001 group-b $ mkstream
OK

redis
├── CycleGeneratorStreamMessageRunner.java # Stream消息生产者，每隔5s产生一个消息
├── RedisStreamApplication.java
├── config
│   └── RedisConfig.java # redis 配置
├── constan
│   └── Cosntants.java # 常量
├── entity
│   └── Book.java # 实体类
└── stream
    ├── consumer # 消费者
    │   ├── group # 消费组
    │   ├── group
    │   │   ├── AsyncConsumeStreamListener.java # 异步消费消息
    │   │   ├── CustomErrorHandler.java # 处理消费消息或读取消息过程中发生的异常
    │   │   └── RedisStreamConfiguration.java # Stream 消费组消费消息
    │   └── xread # 直接消费，此时Stream可以理解成普通的list，但是Stream中的消息在读取后不会消失
    │       ├── XreadNonBlockConsumer01.java    # 非阻塞消费者
    │       └── XreadNonBlockConsumer02.java    # 非阻塞消费者 消费者02和消费者01实现的功能一样，可以看到同一个消息2个消费者都可以消费到
    └── producer
        └── StreamProducer.java # 向Stream中发送消息

java.lang.IllegalArgumentException: Value must not be null!
	at org.springframework.util.Assert.notNull(Assert.java:201)
	at org.springframework.data.redis.connection.stream.Record.of(Record.java:81)
	at org.springframework.data.redis.connection.stream.MapRecord.toObjectRecord(MapRecord.java:147)
	at org.springframework.data.redis.core.StreamObjectMapper.toObjectRecord(StreamObjectMapper.java:138)
	at org.springframework.data.redis.core.StreamObjectMapper.toObjectRecords(StreamObjectMapper.java:164)
	at org.springframework.data.redis.core.StreamOperations.map(StreamOperations.java:594)
	at org.springframework.data.redis.core.StreamOperations.read(StreamOperations.java:413)
	at com.huan.study.redis.stream.consumer.xread.XreadNonBlockConsumer02.lambda$afterPropertiesSet$1(XreadNonBlockConsumer02.java:61)
	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)