Open SakshamPatro opened 1 year ago
const client = new kafka.KafkaClient({ kafkaHost: 'sample.servicebus.windows.net:9093', sasl: { mechanism: 'plain', username: '$ConnectionString', password: 'Endpoint=sb://sample.servicebus.windows.net/;SharedAccessKeyName=db_update;SharedAccessKey=sample+AEhukWIQI=;EntityPath=test_hub' }, requestTimeout: false });
NOTE: I have altered the config but you can see the code above
Request timed out after 30000ms
Thanks for your contribution!
Questions?
Sample Code
const client = new kafka.KafkaClient({ kafkaHost: 'sample.servicebus.windows.net:9093', sasl: { mechanism: 'plain', username: '$ConnectionString', password: 'Endpoint=sb://sample.servicebus.windows.net/;SharedAccessKeyName=db_update;SharedAccessKey=sample+AEhukWIQI=;EntityPath=test_hub' }, requestTimeout: false });
NOTE: I have altered the config but you can see the code above
Output
Request timed out after 30000ms
Thanks for your contribution!