confluent-kafka-javascript

(★ 301)

Confluent's Apache Kafka JavaScript client

파일 탐색기

최종 버전 다운로드 (.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
- - consumer-confluent-cloud.js
  - consumer.js
  - eos.js
  - oauthbearer_oidc_azure_imds.js
  - producer-confluent-cloud.js
  - producer.js
  - sr.js
- - 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
- - meta.proto
- - meta_pb.ts
- - schemaregistry-avro.spec.ts
  - schemaregistry-client.spec.ts
  - schemaregistry-json.spec.ts
- - abstract-oauth-client.ts
  - bearer-token-provider.ts
  - oauth-client-azure-imds.ts
  - oauth-client.ts
  - static-token-provider.ts
- - avro.ts
  - buffer-wrapper.ts
  - json-util.ts
  - json.ts
  - protobuf.ts
  - rule-registry.ts
  - serde.ts
  - wildcard-matcher.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
- - 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
- - docker-compose-kraft.yml
  - docker-compose.yml
  - kafka_jaas.conf
- - high-level-producer.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

# 설치 가이드

1. 코드 내려받기

git clone https://github.com/confluentinc/confluent-kafka-javascript

깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.

cd confluent-kafka-javascript

방금 내려받은 프로젝트 폴더 안으로 이동합니다.

2. Docker

쉬움 추천

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Docker Desktop 컨테이너를 빌드하고 실행하려면 필요합니다. 설치 후 실행해서 백그라운드에 켜두세요.

docker compose -f schemaregistry/docker-compose.schemaregistry.yml up -d --build

compose 설정 파일에 정의된 서비스들을 대상으로 명령을 실행합니다.

✅ 터미널에 docker compose ps 를 입력해 컨테이너들이 Up 상태인지 확인하세요. README에 포트 번호가 적혀있다면 브라우저에서 http://localhost:포트번호 로 접속해보세요.

3. Node.js

쉬움

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Node.js npm 명령어를 쓰려면 Node.js가 설치되어 있어야 합니다. LTS(장기지원) 버전을 추천합니다.

npm install @confluentinc/kafka-javascript

package.json에 명시된 라이브러리들을 내려받아 설치합니다.

✅ 명령어 실행 후 터미널에 나타나는 주소(보통 http://localhost:3000 형태)를 브라우저에서 열어보세요.

이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.

4. Make

보통

사전 준비물

Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
Make Linux/macOS는 보통 기본 설치되어 있습니다. Windows는 별도 설치(예: MSYS2, WSL)가 필요합니다.

make

생성된 빌드 설정을 바탕으로 실제 컴파일을 진행해 실행 파일을 만듭니다.

✅ 에러 없이 끝나면 성공입니다. 생성된 실행 파일을 직접 실행해보세요.