We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6ba9e02 commit 58c3449Copy full SHA for 58c3449
examples/kafkajs/sr.js
@@ -9,10 +9,22 @@ const { SchemaRegistry, SchemaType } = require('@kafkajs/confluent-schema-regist
9
10
const registry = new SchemaRegistry({ host: '<fill>' })
11
const kafka = new Kafka({
12
- brokers: ['<fill>'],
13
- clientId: 'example-consumer',
14
-})
15
-let consumer = kafka.consumer({ groupId: 'test-group' , fromBeginning: true, } );
+ kafkaJS: {
+ brokers: ['<fill>'],
+ ssl: true,
+ sasl: {
16
+ mechanism: 'plain',
17
+ username: '<fill>',
18
+ password: '<fill>',
19
+ },
20
+ }
21
+});
22
+let consumer = kafka.consumer({
23
24
+ groupId: "test-group",
25
+ fromBeginning: false,
26
27
28
let producer = kafka.producer();
29
30
const schemaA = {
0 commit comments