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
4
4
async function consumerStart ( ) {
5
5
let consumer ;
6
6
const kafka = new Kafka ( {
7
- brokers : [ 'pkc-8w6ry7.us-west-2.aws.devel.cpdev.cloud:9092 ' ] ,
7
+ brokers : [ '<fill> ' ] ,
8
8
ssl : true ,
9
9
connectionTimeout : 5000 ,
10
10
sasl : {
11
11
mechanism : 'plain' ,
12
+ username : '<fill>' ,
13
+ password : '<fill>' ,
12
14
} ,
13
15
rebalanceListener : {
14
16
onPartitionsAssigned : async ( assignment ) => {
Original file line number Diff line number Diff line change @@ -3,7 +3,7 @@ const { Kafka } = require('../..').KafkaJS
3
3
4
4
async function producerStart ( ) {
5
5
const kafka = new Kafka ( {
6
- brokers : [ 'pkc-8w6ry7.us-west-2.aws.devel.cpdev.cloud:9092 ' ] ,
6
+ brokers : [ '<fill> ' ] ,
7
7
ssl : true ,
8
8
sasl : {
9
9
mechanism : 'plain' ,
You can’t perform that action at this time.
0 commit comments