Hello! We’ve deployed datahub using k8s and aws tools which are aws rds,es and MSK. I’ve configured recipe.yml and for sink method used datahub-kafka method. Even bootstrap and schema registry urls are proper( i tried to connect and produce and consume with kafka-cli, it’s ok) , i get an error like:

KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"} and info {'error': KafkaError{code=_MSG_TIMED_OUT,val=-192,str="Local: Message timed out"}, 'msg': <cimpl.Message object at 0x10ea17ac0>}

I think somehow, we cannot connect to kafka broker on MSK side from datahub. I wonder, can you please tell what are running k8s pods after deployment?

@early-lamp-41924, could you take a look?

Are you running ingestion using the ingestion-cron or from local?