Не удалось преобразовать Streamz Kafka Stream в Dask Stream

Я не могу преобразовать поток Streamz в поток Dask, созданный с использованием кода Kafka source.PFB.

from streamz import Stream
from streamz.dataframe import Random
from streamz.dataframe import DataFrame
import json
from dask.distributed import Client
client = Client()
source = Stream.from_kafka(['logs'],
       {'bootstrap.servers': 'kafkaXX:9092',
        'group.id': 'streamz'}) 
source.scatter().map(json.loads).buffer(8).gather().sink(print)
source.start()

Я получаю это сообщение об ошибке

ValueError: Two different event loops active