confluent-kafka-javascript
Confluent's Apache Kafka JavaScript client
File Explorer
Download Latest Version (.zip)- bug_report.md
- CODEOWNERS
- pull_request_template.md
- stale.yml
- build-docker-alpine.sh
- build-docker-debian.sh
- docker_run_with_volumes.sh
- post_install.yml
- semaphore.yml
- consumer-raw-rdkafka.js
- consumer-subscribe.js
- kafka-consumer-stream.js
- producer-raw-rdkafka.js
- producer-rdkafka.js
- seed.sh
- librdkafka-correct-version.js
- librdkafka-exists.js
- _install_ckjs.sh
- _install_nvm.sh
- install-alpine.sh
- install-debian.sh
- install-mac.sh
- install-rhel.sh
- run_perf_test.sh
- librdkafka-defs-generator.js
- prepublish.js
- update-version.js
- librdkafka
- librdkafka.gyp
- windows-install.py
- admin-dependent.spec.js
- admin.spec.js
- both.spec.js
- consumer.spec.js
- groups.spec.js
- listener.js
- oauthbearer_cb.spec.js
- producer-transaction.spec.js
- producer.spec.js
- topicUtils.js
- create-topics.js
- delete-groups.js
- delete-topic-records.js
- delete-topics.js
- dependent-admin.js
- describe-groups.js
- fetch-offsets.js
- fetch-topic-metadata.js
- fetch-topic-offsets-by-timestamp.js
- fetch-topic-offsets.js
- list-groups.js
- list-topics.js
- oauthbearer_callback_authentication.js
- package.json
- consumer-confluent-cloud.js
- consumer.js
- eos.js
- oauthbearer_oidc_azure_imds.js
- producer-confluent-cloud.js
- producer.js
- sr.js
- oauthbearer_callback_authentication.js
- package.json
- consumer-confluent-cloud.md
- consumer-flow.md
- consumer.md
- dependent-admin.js
- docker-alpine.md
- high-level-producer-confluent-cloud.md
- high-level-producer.md
- metadata.md
- producer-cluster.md
- producer.md
- package-lock.json
- package.json
- performance-consolidated.js
- performance-primitives-kafkajs.js
- performance-primitives.js
- README.md
- .gitignore
- kafkajs.ts
- node-rdkafka.ts
- package.json
- consumer-confluent-cloud.js
- consumer.js
- eos.js
- package.json
- producer-confluent-cloud.js
- producer.js
- _admin.js
- _common.js
- _consumer.js
- _consumer_cache.js
- _error.js
- _kafka.js
- _linked-list.js
- _producer.js
- index.js
- high-level-producer.js
- ref-counter.js
- admin.js
- client.js
- error.js
- index.js
- kafka-consumer-stream.js
- kafka-consumer.js
- producer-stream.js
- producer.js
- rdkafka.js
- topic-partition.js
- topic.js
- util.js
- decimal.proto
- meta.proto
- aes_gcm.proto
- aes_siv.proto
- cycle.proto
- dep.proto
- example.proto
- nested.proto
- newerwidget.proto
- newwidget.proto
- test.proto
- widget.proto
- decimal_pb.ts
- meta_pb.ts
- schemaregistry-avro.spec.ts
- schemaregistry-client.spec.ts
- schemaregistry-json.spec.ts
- calendar_period_pb.ts
- color_pb.ts
- date_pb.ts
- datetime_pb.ts
- dayofweek_pb.ts
- decimal_pb.ts
- expr_pb.ts
- fraction_pb.ts
- interval_pb.ts
- latlng_pb.ts
- localized_text_pb.ts
- money_pb.ts
- month_pb.ts
- phone_number_pb.ts
- postal_address_pb.ts
- quaternion_pb.ts
- timeofday_pb.ts
- abstract-oauth-client.ts
- bearer-token-provider.ts
- oauth-client-azure-imds.ts
- oauth-client.ts
- static-token-provider.ts
- cel-executor.ts
- cel-field-executor.ts
- aws-client.ts
- aws-driver.ts
- azure-client.ts
- azure-driver.ts
- constants.ts
- dekregistry-client.ts
- mock-dekregistry-client.ts
- gcp-client.ts
- gcp-driver.ts
- hcvault-client.ts
- hcvault-driver.ts
- local-client.ts
- local-driver.ts
- invalid_arguments_exception.ts
- security_exception.ts
- aes_gcm_pb.ts
- aes_siv_pb.ts
- aead.ts
- aes_gcm.ts
- aes_siv.ts
- bytes.ts
- hkdf.ts
- hmac.ts
- mac.ts
- random.ts
- validators.ts
- encrypt-executor.ts
- kms-registry.ts
- jsonata-executor.ts
- avro.ts
- buffer-wrapper.ts
- json-util.ts
- json.ts
- protobuf.ts
- rule-registry.ts
- serde.ts
- wildcard-matcher.ts
- dekregistry-client.spec.ts
- mock-dekregistry-client.spec.ts
- test-constants.ts
- azure-client.spec.ts
- azure-driver.spec.ts
- encrypt-executor.spec.ts
- cycle_pb.ts
- dep_pb.ts
- example_pb.ts
- nested_pb.ts
- newerwidget_pb.ts
- newwidget_pb.ts
- test_pb.ts
- widget_pb.ts
- avro.spec.ts
- buffer-wrapper.spec.ts
- json.spec.ts
- protobuf.spec.ts
- serde.spec.ts
- wildcard-matcher.spec.ts
- mock-schemaregistery-client.spec.ts
- oauth-client-azure-imds.spec.ts
- oauth-client.spec.ts
- rest-service.spec.ts
- schemaregistry-client.spec.ts
- test-constants.ts
- docker-compose.schemaregistry.yml
- index.ts
- jest.config.js
- LICENSE.txt
- Makefile
- mock-schemaregistry-client.ts
- package.json
- README.md
- rest-error.ts
- rest-service.ts
- retry-helper.ts
- run_docker_schemaregistry.sh
- schemaregistry-client.ts
- tsconfig-build.json
- tsconfig.json
- schemaregistry-serialization.spec.ts
- constants.ts
- csfle-schemaregistry.ts
- kafka-consumer-avro.ts
- kafka-consumer-json.ts
- kafka-oauth.ts
- kafka-producer-avro.ts
- kafka-producer-json.ts
- local-schemaregistry.ts
- oauth-schemaregistry.ts
- uami-oauth-schemaregistry.ts
- jest.config.js
- package.json
- tsconfig.json
- update-changelog.py
- admin.cc
- admin.h
- binding.cc
- binding.h
- callbacks.cc
- callbacks.h
- common.cc
- common.h
- config.cc
- config.h
- connection.cc
- connection.h
- errors.cc
- errors.h
- kafka-consumer.cc
- kafka-consumer.h
- producer.cc
- producer.h
- topic.cc
- topic.h
- workers.cc
- workers.h
- server.properties
- docker-compose-kraft.yml
- docker-compose.yml
- kafka_jaas.conf
- high-level-producer.spec.js
- create_topics.spec.js
- delete_groups.spec.js
- delete_topic_records.spec.js
- dependent_client.spec.js
- describe_groups.spec.js
- fetch_offsets.spec.js
- fetch_topic_metadata.spec.js
- fetch_topic_offsets.spec.js
- fetch_topic_offsets_by_timestamp.spec.js
- list_groups.spec.js
- list_topics.spec.js
- statsCallback.spec.js
- commit.spec.js
- consumeMessages.spec.js
- consumerCacheTests.spec.js
- consumerTransactions.spec.js
- groupInstanceId.spec.js
- incrementalRebalance.spec.js
- pause.spec.js
- pauseSeekResume.spec.js
- rebalanceCallback.spec.js
- seek.spec.js
- statsCallback.spec.js
- subscribe.spec.js
- concurrentSend.spec.js
- concurrentTransaction.spec.js
- eos.spec.js
- flush.spec.js
- idempotentProduceMessage.spec.js
- producingToInvalidTopic.spec.js
- statsCallback.spec.js
- cache.spec.js
- common.spec.js
- logger.spec.js
- oauthbearer_cb.spec.js
- testhelpers.js
- ref-counter.spec.js
- binding.spec.js
- consumer.spec.js
- error.spec.js
- index.spec.js
- kafka-consumer-stream.spec.js
- kafka-consumer.spec.js
- mocha.opts
- mock.js
- producer-stream.spec.js
- producer.spec.js
- topic-partition.spec.js
- util.spec.js
- config.d.ts
- errors.d.ts
- kafkajs.d.ts
- rdkafka.d.ts
- configure.js
- generate-docs.sh
- get-env.js
- test-compile.js
- test-producer-delivery.js
- .editorconfig
- .gitignore
- .gitmodules
- .npmignore
- binding.gyp
- buf.gen.yaml
- CHANGELOG.md
- configure
- CONTRIBUTING.md
- cpplint.py
- deploy.enc
- eslint.config.js
- index.d.ts
- INTRODUCTION.md
- jest.config.js
- jsdoc.conf
- librdkafka.js
- LICENSE.kafkajs
- LICENSE.node-rdkafka
- LICENSE.txt
- make_docs.sh
- Makefile
- MIGRATION.md
- package-lock.json
- package.json
- QUICKSTART.md
- README.md
- run_docker.sh
- SECURITY.md
- service.yml
- sonar-project.properties
- tsconfig.json
- win_install.ps1
// repository documentation
Was this content helpful?
(0 ratings)