Awesome, I faced the problem which I did not create a topic from the Kafka side. I directly subscribe or publish messages for them, and it works fine with one replica of the instance. But when having a horizontal scaling, only 1 replica will listen to the event with the below setup error:

KafkaJSProtocolError: This server does not host this topic-partition type: 'UNKNOWN_TOPIC_OR_PARTITION',

In conclusion, the default partition is 1. if you want to update it you need to create The topic and the partition as the above Code.

Thanks.