File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -4,11 +4,13 @@ const { Kafka } = require('../..').KafkaJS
44async function consumerStart ( ) {
55 let consumer ;
66 const kafka = new Kafka ( {
7- brokers : [ 'pkc-8w6ry7.us-west-2.aws.devel.cpdev.cloud:9092 ' ] ,
7+ brokers : [ '<fill> ' ] ,
88 ssl : true ,
99 connectionTimeout : 5000 ,
1010 sasl : {
1111 mechanism : 'plain' ,
12+ username : '<fill>' ,
13+ password : '<fill>' ,
1214 } ,
1315 rebalanceListener : {
1416 onPartitionsAssigned : async ( assignment ) => {
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ const { Kafka } = require('../..').KafkaJS
33
44async function producerStart ( ) {
55 const kafka = new Kafka ( {
6- brokers : [ 'pkc-8w6ry7.us-west-2.aws.devel.cpdev.cloud:9092 ' ] ,
6+ brokers : [ '<fill> ' ] ,
77 ssl : true ,
88 sasl : {
99 mechanism : 'plain' ,
You can’t perform that action at this time.
0 commit comments