RedisDomainEventBus
constructor(redisTemplate: ReactiveStringRedisTemplate, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2))
constructor(redisTemplate: ReactiveStringRedisTemplate, recoveryOptions: RedisStreamRecoveryOptions, observer: RedisMessageBusObserver = RedisMessageBusObserver.NOOP, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter, pollTimeout: Duration = Duration.ofSeconds(2))