Add copyright notices and change imports

Author: milindl

INTRODUCTION.md

@@ -25,7 +25,7 @@ This library includes two utility functions for detecting the status of your ins
 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.
 
 ```js
-const Kafka = require('confluent-kafka-javascript');
+const Kafka = require('@confluentinc/kafka-javascript');
 console.log(Kafka.features);
 
 // #=> [ 'gzip', 'snappy', 'ssl', 'sasl', 'regex', 'lz4' ]
@@ -34,7 +34,7 @@ console.log(Kafka.features);
 You can also get the version of `librdkafka`
 
 ```js
-const Kafka = require('confluent-kafka-javascript');
+const Kafka = require('@confluentinc/kafka-javascript');
 console.log(Kafka.librdkafkaVersion);
 
 // #=> 2.3.0
@@ -512,7 +512,7 @@ producer.getMetadata(opts, (err, metadata) => {
 To create an Admin client, you can do as follows:
 
 ```js
-const Kafka = require('confluent-kafka-javascript');
+const Kafka = require('@confluentinc/kafka-javascript');
 
 const client = Kafka.AdminClient.create({
   'client.id': 'kafka-admin',

MIGRATION.md

@@ -11,7 +11,7 @@
     ```
     to
     ```javascript
-    const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
+    const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
     const kafka = new Kafka({ kafkaJS: { brokers: ['kafka1:9092', 'kafka2:9092'], /* ... */ } });
     const producer = kafka.producer({ kafkaJS: { /* ... */, } });
     ```
@@ -35,7 +35,7 @@
 
 ```diff
 -const { Kafka } = require('kafkajs');
-+const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
++const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
 
 const kafka = new Kafka({
 + kafkaJS: {
@@ -371,6 +371,6 @@ Change the import statement, from
   ```
   to
   ```javascript
-  const Kafka = require('confluent-kafka-javascript');
+  const Kafka = require('@confluentinc/kafka-javascript');
   ```
 The rest of the functionality should work as usual.

README.md

@@ -20,8 +20,8 @@ We invite you to raise issues to highlight any feedback you may have.
 
 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.
 
-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". 
- 
+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".
+
 
 ## Requirements
 
@@ -34,7 +34,7 @@ The following configurations are supported for this early access preview:
 Installation on any of these platforms is meant to be seamless, without any C/C++ compilation required. It can be installed from GitHub:
 
 ```bash
-$ npm install @confluentinc/confluent-kafka-javascript
+$ npm install @confluentinc/kafka-javascript
 ```
 
 Yarn and pnpm support is experimental.
@@ -44,8 +44,8 @@ Yarn and pnpm support is experimental.
 Below is a simple produce example for users migrating from KafkaJS.
 
 ```javascript
-// require('kafkajs') is replaced with require('confluent-kafka-javascript').KafkaJS.
-const { Kafka } = require("confluent-kafka-javascript").KafkaJS;
+// require('kafkajs') is replaced with require('@confluentinc/kafka-javascript').KafkaJS.
+const { Kafka } = require("@confluentinc/kafka-javascript").KafkaJS;
 
 async function producerStart() {
     const kafka = new Kafka({

examples/consumer.js

@@ -1,4 +1,4 @@
-const { Kafka, ErrorCodes } = require('confluent-kafka-javascript').KafkaJS;
+const { Kafka, ErrorCodes } = require('@confluentinc/kafka-javascript').KafkaJS;
 
 async function consumerStart() {
   let consumer;

examples/eos.js

@@ -1,4 +1,4 @@
-const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
+const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
 
 async function eosStart() {
     const consumer = new Kafka().consumer({

examples/kafkajs/admin.js

@@ -1,4 +1,4 @@
-// require('kafkajs') is replaced with require('confluent-kafka-javascript').KafkaJS.
+// require('kafkajs') is replaced with require('@confluentinc/kafka-javascript').KafkaJS.
 // Since this example is within the package itself, we use '../..', but code
 // will typically use 'confluent-kafka-javascript'.
 const { Kafka } = require('../..').KafkaJS;

examples/kafkajs/sr.js

@@ -1,4 +1,4 @@
-// require('kafkajs') is replaced with require('confluent-kafka-javascript').KafkaJS.
+// require('kafkajs') is replaced with require('@confluentinc/kafka-javascript').KafkaJS.
 // Since this example is within the package itself, we use '../..', but code
 // will typically use 'confluent-kafka-javascript'.
 const { Kafka } = require('../..').KafkaJS;

examples/producer.js

@@ -1,4 +1,4 @@
-const { Kafka } = require('confluent-kafka-javascript').KafkaJS;
+const { Kafka } = require('@confluentinc/kafka-javascript').KafkaJS;
 
 async function producerStart() {
     const producer = new Kafka().producer({

lib/client.js

@@ -2,6 +2,7 @@
  * confluent-kafka-javascript - Node.js wrapper  for RdKafka C/C++ library
  *
  * Copyright (c) 2016-2023 Blizzard Entertainment
+ *           (c) 2023 Confluent, Inc.
  *
  * This software may be modified and distributed under the terms
  * of the MIT license.  See the LICENSE.txt file for details.
@@ -14,7 +15,7 @@ var util = require('util');
 var Kafka = require('../librdkafka.js');
 var assert = require('assert');
 
-const bindingVersion = 'v0.1.8-devel';
+const bindingVersion = 'v0.1.9-devel';
 
 var LibrdKafkaError = require('./error');
 

lib/kafka-consumer.js

@@ -2,6 +2,7 @@
  * confluent-kafka-javascript - Node.js wrapper  for RdKafka C/C++ library
  *
  * Copyright (c) 2016-2023 Blizzard Entertainment
+ *           (c) 2023 Confluent, Inc.
  *
  * This software may be modified and distributed under the terms
  * of the MIT license.  See the LICENSE.txt file for details.