* added other parameters for queue kafka * Added support Confluent Cloud * fix js executor kafka connection * refactored