How to handle node where aws kinesis input thread is running

Hi,

We have 2 node graylog cluster and we found that at any point aws kinesis input thread will be running in only one graylog node.

Also we found that if graylog node where this thread is running goes down, their no way that active graylog will recreate that thread to continue consuming messages.

Please let us know if their is a way to handle this scenario.

Thanks