Я пытаюсь использовать один поток, обрабатывать входящий формат json и записывать в разные потоки на основе атрибута в событии. Например, если входной поток состоит из чего-то вроде этого: { "event_type" : "temperature", "json" : {...