Skip to content

Commit 924d0d3

Browse files
committed
Add copyright notices and change imports
1 parent a985041 commit 924d0d3

21 files changed

+34
-23
lines changed

INTRODUCTION.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ This library includes two utility functions for detecting the status of your ins
2525
You can get the features supported by your compile of `librdkafka` by reading the variable "features" on the root of the `confluent-kafka-javascript` object.
2626

2727
```js
28-
const Kafka = require('confluent-kafka-javascript');
28+
const Kafka = require('@confluentinc/kafka-javascript');
2929
console.log(Kafka.features);
3030

3131
// #=> [ 'gzip', 'snappy', 'ssl', 'sasl', 'regex', 'lz4' ]
@@ -34,7 +34,7 @@ console.log(Kafka.features);
3434
You can also get the version of `librdkafka`
3535

3636
```js
37-
const Kafka = require('confluent-kafka-javascript');
37+
const Kafka = require('@confluentinc/kafka-javascript');
3838
console.log(Kafka.librdkafkaVersion);
3939

4040
// #=> 2.3.0
@@ -512,7 +512,7 @@ producer.getMetadata(opts, (err, metadata) => {
512512
To create an Admin client, you can do as follows:
513513

514514
```js
515-
const Kafka = require('confluent-kafka-javascript');
515+
const Kafka = require('@confluentinc/kafka-javascript');
516516

517517
const client = Kafka.AdminClient.create({
518518
'client.id': 'kafka-admin',

MIGRATION.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
```
1212
to
1313
```javascript
14-
const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
14+
const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
1515
const kafka = new Kafka({ kafkaJS: { brokers: ['kafka1:9092', 'kafka2:9092'], /* ... */ } });
1616
const producer = kafka.producer({ kafkaJS: { /* ... */, } });
1717
```
@@ -35,7 +35,7 @@
3535

3636
```diff
3737
-const { Kafka } = require('kafkajs');
38-
+const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
38+
+const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
3939
4040
const kafka = new Kafka({
4141
+ kafkaJS: {
@@ -371,6 +371,6 @@ Change the import statement, from
371371
```
372372
to
373373
```javascript
374-
const Kafka = require('confluent-kafka-javascript');
374+
const Kafka = require('@confluentinc/kafka-javascript');
375375
```
376376
The rest of the functionality should work as usual.

README.md

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,8 @@ We invite you to raise issues to highlight any feedback you may have.
2020

2121
Within the early-access, only **basic produce and consume functionality** as well as the ability to **create and delete topics** are supported. All other admin client functionality is coming in future releases. See [INTRODUCTION.md](INTRODUCTION.md) for more details on what is supported.
2222

23-
To use **Schema Registry**, use the existing [kafkajs/confluent-schema-registry](https://github.com/kafkajs/confluent-schema-registry) library that is compatible with this library. For a simple schema registry example, see [sr.js](https://github.com/confluentinc/confluent-kafka-javascript/blob/dev_early_access_development_branch/examples/kafkajs/sr.js). **DISCLAIMER:** Although it is compatible with **confluent-kafka-javascript**, Confluent does not own or maintain kafkajs/confluent-schema-registry, and the use and functionality of the library should be considered "as is".
24-
23+
To use **Schema Registry**, use the existing [kafkajs/confluent-schema-registry](https://github.com/kafkajs/confluent-schema-registry) library that is compatible with this library. For a simple schema registry example, see [sr.js](https://github.com/confluentinc/confluent-kafka-javascript/blob/dev_early_access_development_branch/examples/kafkajs/sr.js). **DISCLAIMER:** Although it is compatible with **confluent-kafka-javascript**, Confluent does not own or maintain kafkajs/confluent-schema-registry, and the use and functionality of the library should be considered "as is".
24+
2525

2626
## Requirements
2727

@@ -34,7 +34,7 @@ The following configurations are supported for this early access preview:
3434
Installation on any of these platforms is meant to be seamless, without any C/C++ compilation required. It can be installed from GitHub:
3535

3636
```bash
37-
$ npm install @confluentinc/confluent-kafka-javascript
37+
$ npm install @confluentinc/kafka-javascript
3838
```
3939

4040
Yarn and pnpm support is experimental.
@@ -44,8 +44,8 @@ Yarn and pnpm support is experimental.
4444
Below is a simple produce example for users migrating from KafkaJS.
4545

4646
```javascript
47-
// require('kafkajs') is replaced with require('confluent-kafka-javascript').KafkaJS.
48-
const { Kafka } = require("confluent-kafka-javascript").KafkaJS;
47+
// require('kafkajs') is replaced with require('@confluentinc/kafka-javascript').KafkaJS.
48+
const { Kafka } = require("@confluentinc/kafka-javascript").KafkaJS;
4949

5050
async function producerStart() {
5151
const kafka = new Kafka({

examples/consumer.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
const { Kafka, ErrorCodes } = require('confluent-kafka-javascript').KafkaJS;
1+
const { Kafka, ErrorCodes } = require('@confluentinc/kafka-javascript').KafkaJS;
22

33
async function consumerStart() {
44
let consumer;

examples/eos.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
1+
const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
22

33
async function eosStart() {
44
const consumer = new Kafka().consumer({

examples/kafkajs/admin.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// require('kafkajs') is replaced with require('confluent-kafka-javascript').KafkaJS.
1+
// require('kafkajs') is replaced with require('@confluentinc/kafka-javascript').KafkaJS.
22
// Since this example is within the package itself, we use '../..', but code
33
// will typically use 'confluent-kafka-javascript'.
44
const { Kafka } = require('../..').KafkaJS;

examples/kafkajs/sr.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// require('kafkajs') is replaced with require('confluent-kafka-javascript').KafkaJS.
1+
// require('kafkajs') is replaced with require('@confluentinc/kafka-javascript').KafkaJS.
22
// Since this example is within the package itself, we use '../..', but code
33
// will typically use 'confluent-kafka-javascript'.
44
const { Kafka } = require('../..').KafkaJS;

examples/producer.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
1+
const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
22

33
async function producerStart() {
44
const producer = new Kafka().producer({

lib/client.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.
@@ -14,7 +15,7 @@ var util = require('util');
1415
var Kafka = require('../librdkafka.js');
1516
var assert = require('assert');
1617

17-
const bindingVersion = 'v0.1.8-devel';
18+
const bindingVersion = 'v0.1.9-devel';
1819

1920
var LibrdKafkaError = require('./error');
2021

lib/kafka-consumer.js

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

package-lock.json

Lines changed: 4 additions & 4 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
2-
"name": "confluent-kafka-javascript",
3-
"version": "v0.1.8-devel",
2+
"name": "@confluentinc/kafka-javascript",
3+
"version": "v0.1.9-devel",
44
"description": "Node.js bindings for librdkafka",
55
"librdkafka": "master",
66
"librdkafka_win": "2.3.0",

src/admin.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/callbacks.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/callbacks.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
/*
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
* Copyright (c) 2016-2023 Blizzard Entertainment
4+
* (c) 2023 Confluent, Inc.
45
*
56
* This software may be modified and distributed under the terms
67
* of the MIT license. See the LICENSE.txt file for details.

src/connection.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/connection.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/kafka-consumer.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/kafka-consumer.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/producer.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

src/workers.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
* confluent-kafka-javascript - Node.js wrapper for RdKafka C/C++ library
33
*
44
* Copyright (c) 2016-2023 Blizzard Entertainment
5+
* (c) 2023 Confluent, Inc.
56
*
67
* This software may be modified and distributed under the terms
78
* of the MIT license. See the LICENSE.txt file for details.

0 commit comments

Comments
 (0)