Pulsar 커넥터 사용법

Pulsar 커넥터 사용법 (How to use Pulsar connectors)

이 가이드는 Pulsar 커넥터를 사용하는 방법을 설명해요. 커넥터는 Pulsar와 외부 시스템(데이터베이스, 메시징 시스템 등) 사이의 데이터 이동을 담당해요. 설치부터 구성, 실행, 모니터링, 업데이트까지 커넥터의 전체 생명주기를 함께 살펴볼게요.

출처: 문서

본문

커넥터 설치 (Install a connector)

Pulsar는 일반적으로 사용되는 시스템(데이터베이스, 메시징 시스템 등)과 데이터를 주고받기 위한 여러 내장 커넥터를 번들로 제공해요. 선택적으로 원하는 비내장 커넥터를 만들어 사용할 수도 있어요.

note 비내장 커넥터를 사용할 때는 커넥터의 아카이브 파일 경로를 지정해야 해요.

내장 커넥터를 설정하려면 안내를 따라요.

설정 후 내장 커넥터는 Pulsar 브로커(또는 function-worker)가 자동으로 발견하므로 추가 설치 단계가 필요하지 않아요.

커넥터 구성 (Configure a connector)

다음 정보를 구성할 수 있어요.

내장 커넥터의 기본 저장 위치 구성 (Configure a default storage location for a built-in connector)

내장 커넥터의 기본 폴더를 구성하려면 ./conf/functions_worker.yml 구성 파일에서 connectorsDirectory 파라미터를 설정해요.

예시 (Example)

내장 커넥터의 기본 저장 위치로 ./connectors 폴더를 설정해요.

#########################
Connectors
#########################
connectorsDirectory: ./connectors

YAML 파일로 커넥터 구성 (Configure a connector with a YAML file)

커넥터를 구성하려면 커넥터를 만들 때 YAML 구성 파일을 제공해야 해요.

YAML 구성 파일은 Pulsar에 커넥터를 어디서 찾을 수 있고 커넥터를 Pulsar 토픽과 어떻게 연결하는지 알려줘요.

예시 1 (Example 1)

아래는 Cassandra 싱크의 YAML 구성 파일이에요. Pulsar에 다음을 알려줘요.

  • 어떤 Cassandra 클러스터에 연결할지
  • 데이터 수집에 사용할 Cassandra의 keyspace와 columnFamily가 무엇인지
  • Pulsar 메시지를 Cassandra 테이블 키와 컬럼에 어떻게 매핑할지
tenant: public
namespace: default
name: cassandra-test-sink
...
# cassandra specific config
configs:
    roots: "localhost:9042"
    keyspace: "pulsar_test_keyspace"
    columnFamily: "pulsar_test_table"
    keyname: "key"
    columnName: "col"

예시 2 (Example 2)

아래는 Kafka 소스의 YAML 구성 파일이에요.

configs:
  bootstrapServers: "pulsar-kafka:9092"
  groupId: "test-pulsar-io"
  topic: "my-topic"
  sessionTimeoutMs: "10000"
  autoCommitEnabled: "false"

예시 3 (Example 3)

아래는 PostgreSQL JDBC 싱크의 YAML 구성 파일이에요.

configs:
  userName: "postgres"
  password: "password"
  jdbcUrl: "jdbc:postgresql://localhost:5432/test_jdbc"
  tableName: "test_jdbc"

커넥터 준비 (Prepare a connector)

커넥터 사용을 시작하기 전에 다음 작업을 수행할 수 있어요.

reload

커넥터 폴더에서 nar 파일을 추가하거나 삭제했다면, 사용하기 전에 사용 가능한 내장 커넥터를 다시 로드해요.

소스 (Source)

소스 커넥터를 다시 로드하려면 reload 하위 명령을 사용해요.

pulsar-admin sources reload

최신·완전한 정보는 Pulsar admin docs를 참고해요.

싱크 (Sink)

싱크 커넥터를 다시 로드하려면 reload 하위 명령을 사용해요.

pulsar-admin sinks reload

최신·완전한 정보는 Pulsar admin docs를 참고해요.

available

커넥터를 다시 로드한 뒤(선택) 사용 가능한 커넥터 목록을 얻을 수 있어요.

소스 (Source)

소스 커넥터 목록을 얻으려면 available-sources 하위 명령을 사용해요.

pulsar-admin sources available-sources
싱크 (Sink)

싱크 커넥터 목록을 얻으려면 available-sinks 하위 명령을 사용해요.

pulsar-admin sinks available-sinks

커넥터 실행 (Run a connector)

커넥터를 실행하려면 다음 작업을 수행할 수 있어요.

create

커넥터를 생성하려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

소스 커넥터를 만들려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

create 하위 명령을 사용해요.

pulsar-admin sources create options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 POST 요청을 보내요: POST /admin/v3/sources/{tenant}/{namespace}/{sourceName}

  • 로컬 파일로 소스 커넥터 생성.
void createSource(SourceConfig sourceConfig,
                  String fileName)
           throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | sourceConfig | 소스 구성 객체 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 createSource를 참고해요.

  • fun-pkg를 내려받을 수 있는 URL의 원격 파일로 소스 커넥터 생성.
void createSourceWithUrl(SourceConfig sourceConfig,
                         String pkgUrl)
                  throws PulsarAdminException

지원되는 URL은 http와 file이에요.

예시 (Example)

파라미터 (Parameter)

| 파라미터 | 설명 | | sourceConfig | 소스 구성 객체 | | pkgUrl | pkg를 내려받을 수 있는 URL |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 createSourceWithUrl를 참고해요.

싱크 (Sink)

싱크 커넥터를 만들려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

create 하위 명령을 사용해요.

pulsar-admin sinks create options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 POST 요청을 보내요: POST /admin/v3/sinks/{tenant}/{namespace}/{sinkName}

  • 로컬 파일로 싱크 커넥터 생성.
void createSink(SinkConfig sinkConfig,
                String fileName)
         throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | sinkConfig | 싱크 구성 객체 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 createSink를 참고해요.

  • fun-pkg를 내려받을 수 있는 URL의 원격 파일로 싱크 커넥터 생성.
void createSinkWithUrl(SinkConfig sinkConfig,
                    String pkgUrl)
                throws PulsarAdminException

지원되는 URL은 http와 file이에요.

예시 (Example)

파라미터 (Parameter)

| 파라미터 | 설명 | | sinkConfig | 싱크 구성 객체 | | pkgUrl | pkg를 내려받을 수 있는 URL |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 createSinkWithUrl를 참고해요.

start

커넥터를 시작하려면 Admin CLI 또는 REST API를 사용할 수 있어요.

소스 (Source)

소스 커넥터를 시작하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API

start 하위 명령을 사용해요.

pulsar-admin sources start options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

싱크 (Sink)

싱크 커넥터를 시작하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API

start 하위 명령을 사용해요.

pulsar-admin sinks start options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

localrun

커넥터를 Pulsar 클러스터에 배포하지 않고 로컬로 실행하려면 Admin CLI를 사용할 수 있어요.

소스 (Source)

소스 커넥터를 로컬로 실행하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI

localrun 하위 명령을 사용해요.

pulsar-admin sources localrun options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

싱크 (Sink)

싱크 커넥터를 로컬로 실행하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI

localrun 하위 명령을 사용해요.

pulsar-admin sinks localrun options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

싱크 커넥터 전에 Pulsar Function 실행 (Run a Pulsar Function before a sink connector)

싱크 커넥터 앞에서 Pulsar Function을 메모리로 실행할 수 있어요. 자세한 내용은 PIP 193: Sink preprocessing Function을 참고해요.

싱크 커넥터 앞에서 Pulsar Function을 메모리로 실행하면 중간 토픽을 거치는 것보다 지연 시간이 낮고 I/O와 디스크 소비가 적어요.

싱크 커넥터를 만들 때 --transform-function, --transform-function-classname, --transform-function-config 옵션을 사용해 실행할 transform Function을 구성할 수 있어요.

최신·완전한 정보는 Pulsar admin sinks command docs를 참고해요.

커넥터 모니터링 (Monitor a connector)

커넥터를 모니터링하려면 다음 작업을 수행할 수 있어요.

get

커넥터의 정보를 얻으려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

소스 커넥터의 정보를 얻으려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

get 하위 명령을 사용해요.

pulsar-admin sources get options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 GET 요청을 보내요: GET /admin/v3/sources/{tenant}/{namespace}/{sourceName}

SourceConfig getSource(String tenant,
                       String namespace,
                       String source)
                throws PulsarAdminException

예시 (Example) 이것은 sourceConfig예요.

{
  "tenant": "tenantName",
  "namespace": "namespaceName",
  "name": "sourceName",
  "className": "className",
  "topicName": "topicName",
  "configs": {},
  "parallelism": 1,
  "processingGuarantees": "ATLEAST_ONCE",
  "resources": {
    "cpu": 1.0,
    "ram": 1073741824,
    "disk": 10737418240
  }
}

이것은 sourceConfig 예시예요.

{
  "tenant": "public",
  "namespace": "default",
  "name": "debezium-mysql-source",
  "className": "org.apache.pulsar.io.debezium.mysql.DebeziumMysqlSource",
  "topicName": "debezium-mysql-topic",
  "configs": {
    "database.user": "debezium",
    "database.server.id": "184054",
    "database.server.name": "dbserver1",
    "database.port": "3306",
    "database.hostname": "localhost",
    "database.password": "dbz",
    "database.history.pulsar.service.url": "pulsar://127.0.0.1:6650",
    "value.converter": "org.apache.kafka.connect.json.JsonConverter",
    "database.whitelist": "inventory",
    "key.converter": "org.apache.kafka.connect.json.JsonConverter",
    "database.history": "org.apache.pulsar.io.debezium.PulsarDatabaseHistory",
    "pulsar.service.url": "pulsar://127.0.0.1:6650",
    "database.history.pulsar.topic": "history-topic2"
  },
  "parallelism": 1,
  "processingGuarantees": "ATLEAST_ONCE",
  "resources": {
    "cpu": 1.0,
    "ram": 1073741824,
    "disk": 10737418240
  }
}

예외 (Exception)

| 예외 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 getSource를 참고해요.

싱크 (Sink)

싱크 커넥터의 정보를 얻으려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

get 하위 명령을 사용해요.

pulsar-admin sinks get options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 GET 요청을 보내요: GET /admin/v3/sinks/{tenant}/{namespace}/{sinkName}

SinkConfig getSink(String tenant,
                   String namespace,
                   String sink)
            throws PulsarAdminException

예시 (Example) 이것은 sinkConfig예요.

{
"tenant": "tenantName",
"namespace": "namespaceName",
"name": "sinkName",
"className": "className",
"inputSpecs": {
"topicName": {
    "isRegexPattern": false
}},
"configs": {},
"parallelism": 1,
"processingGuarantees": "ATLEAST_ONCE",
"retainOrdering": false,
"autoAck": true
}

이것은 sinkConfig 예시예요.

{
  "tenant": "public",
  "namespace": "default",
  "name": "pulsar-postgres-jdbc-sink",
  "className": "org.apache.pulsar.io.jdbc.PostgresJdbcAutoSchemaSink",
  "inputSpecs": {
  "pulsar-postgres-jdbc-sink-topic": {
     "isRegexPattern": false
    }
  },
  "configs": {
    "password": "password",
    "jdbcUrl": "jdbc:postgresql://localhost:5432/pulsar_postgres_jdbc_sink",
    "userName": "postgres",
    "tableName": "pulsar_postgres_jdbc_sink"
  },
  "parallelism": 1,
  "processingGuarantees": "ATLEAST_ONCE",
  "retainOrdering": false,
  "autoAck": true
}

파라미터 설명 (Parameter description)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 싱크 이름 |

자세한 내용은 getSink를 참고해요.

list

실행 중인 모든 커넥터의 목록을 얻으려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

실행 중인 모든 소스 커넥터의 목록을 얻으려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

list 하위 명령을 사용해요.

pulsar-admin sources list options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 GET 요청을 보내요: GET /admin/v3/sources/{tenant}/{namespace}

List<String> listSources(String tenant,
                         String namespace)
                  throws PulsarAdminException

응답 예시 (Response example)

["f1", "f2", "f3"]

예외 (Exception)

| 예외 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 listSource를 참고해요.

싱크 (Sink)

실행 중인 모든 싱크 커넥터의 목록을 얻으려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

list 하위 명령을 사용해요.

pulsar-admin sinks list options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 GET 요청을 보내요: GET /admin/v3/sinks/{tenant}/{namespace}

List<String> listSinks(String tenant,
                       String namespace)
                throws PulsarAdminException

응답 예시 (Response example)

["f1", "f2", "f3"]

예외 (Exception)

| 예외 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 listSource를 참고해요.

status

커넥터의 현재 상태를 얻으려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

소스 커넥터의 현재 상태를 얻으려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

status 하위 명령을 사용해요.

pulsar-admin sources status options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

SourceStatus getSourceStatus(String tenant,
                            String namespace,
                            String source)
                    throws PulsarAdminException

파라미터 (Parameter)

| 파라미터 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 소스 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 getSourceStatus를 참고해요.

  • 특정 소스 커넥터의 현재 상태 얻기.
SourceStatus.SourceInstanceStatus.SourceInstanceStatusData getSourceStatus(String tenant,
                                                                           String namespace,
                                                                           String source,
                                                                           int id)
                                                                    throws PulsarAdminException

파라미터 (Parameter)

| 파라미터 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 소스 이름 | | id | 소스 인스턴스 ID |

예외 (Exception)

| 예외 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 getSourceStatus를 참고해요.

싱크 (Sink)

Pulsar 싱크 커넥터의 현재 상태를 얻으려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

status 하위 명령을 사용해요.

pulsar-admin sinks status options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

SinkStatus getSinkStatus(String tenant,
                         String namespace,
                         String sink)
                  throws PulsarAdminException

파라미터 (Parameter)

| 파라미터 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 소스 이름 |

예외 (Exception)

| 예외 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 getSinkStatus를 참고해요.

  • 특정 소스 커넥터의 현재 상태 얻기.
SinkStatus.SinkInstanceStatus.SinkInstanceStatusData getSinkStatus(String tenant,
                                                                   String namespace,
                                                                   String sink,
                                                                   int id)
                                                            throws PulsarAdminException

파라미터 (Parameter)

| 파라미터 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 소스 이름 | | id | 싱크 인스턴스 ID |

예외 (Exception)

| 예외 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 getSinkStatusWithInstanceID를 참고해요.

커넥터 업데이트 (Update a connector)

update

실행 중인 커넥터를 업데이트하려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

실행 중인 Pulsar 소스 커넥터를 업데이트하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

update 하위 명령을 사용해요.

pulsar-admin sources update options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 PUT 요청을 보내요: PUT /admin/v3/sources/{tenant}/{namespace}/{sourceName}

  • 로컬 파일로 실행 중인 소스 커넥터 업데이트.
void updateSource(SourceConfig sourceConfig,
                String fileName)
        throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | sourceConfig | 소스 구성 객체 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 updateSource를 참고해요.

  • fun-pkg를 내려받을 수 있는 URL의 원격 파일로 소스 커넥터 업데이트.
void updateSourceWithUrl(SourceConfig sourceConfig,
                     String pkgUrl)
              throws PulsarAdminException

지원되는 URL은 http와 file이에요.

예시 (Example)

파라미터 (Parameter)

| 이름 | 설명 | | sourceConfig | 소스 구성 객체 | | pkgUrl | pkg를 내려받을 수 있는 URL |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 createSourceWithUrl를 참고해요.

싱크 (Sink)

실행 중인 Pulsar 싱크 커넥터를 업데이트하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

update 하위 명령을 사용해요.

pulsar-admin sinks update options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

이 엔드포인트에 PUT 요청을 보내요: PUT /admin/v3/sinks/{tenant}/{namespace}/{sinkName}

  • 로컬 파일로 실행 중인 싱크 커넥터 업데이트.
void updateSink(SinkConfig sinkConfig,
                String fileName)
     throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | sinkConfig | 싱크 구성 객체 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 updateSink를 참고해요.

  • fun-pkg를 내려받을 수 있는 URL의 원격 파일로 싱크 커넥터 업데이트.
void updateSinkWithUrl(SinkConfig sinkConfig,
                       String pkgUrl)
                throws PulsarAdminException

지원되는 URL은 http와 file이에요.

예시 (Example)

파라미터 (Parameter)

| 이름 | 설명 | | sinkConfig | 싱크 구성 객체 | | pkgUrl | pkg를 내려받을 수 있는 URL |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 updateSinkWithUrl를 참고해요.

커넥터 중지 (Stop a connector)

stop

커넥터를 중지하려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

소스 커넥터를 중지하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

stop 하위 명령을 사용해요.

pulsar-admin sources stop options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

void stopSource(String tenant,
                String namespace,
                String source)
        throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 stopSource를 참고해요.

  • 특정 소스 커넥터 중지.
void stopSource(String tenant,
                String namespace,
                String source,
                int instanceId)
         throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 | | instanceId | 소스 인스턴스 ID |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 stopSource를 참고해요.

싱크 (Sink)

싱크 커넥터를 중지하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

stop 하위 명령을 사용해요.

pulsar-admin sinks stop options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

void stopSink(String tenant,
            String namespace,
            String sink)
    throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 stopSink를 참고해요.

  • 특정 싱크 커넥터 중지.
void stopSink(String tenant,
              String namespace,
              String sink,
              int instanceId)
       throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 | | instanceId | 소스 인스턴스 ID |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 stopSink를 참고해요.

커넥터 재시작 (Restart a connector)

restart

커넥터를 재시작하려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

소스 커넥터를 재시작하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

restart 하위 명령을 사용해요.

pulsar-admin sources restart options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

void restartSource(String tenant,
                   String namespace,
                   String source)
            throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 restartSource를 참고해요.

  • 특정 소스 커넥터 재시작.
void restartSource(String tenant,
                   String namespace,
                   String source,
                   int instanceId)
            throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 | | instanceId | 소스 인스턴스 ID |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 restartSource를 참고해요.

싱크 (Sink)

싱크 커넥터를 재시작하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

restart 하위 명령을 사용해요.

pulsar-admin sinks restart options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

void restartSink(String tenant,
                 String namespace,
                 String sink)
          throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 싱크 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 restartSink를 참고해요.

  • 특정 싱크 커넥터 재시작.
void restartSink(String tenant,
                 String namespace,
                 String sink,
                 int instanceId)
          throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 | | instanceId | 싱크 인스턴스 ID |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 restartSink를 참고해요.

커넥터 삭제 (Delete a connector)

delete

커넥터를 삭제하려면 Admin CLI, REST API 또는 JAVA admin API를 사용할 수 있어요.

소스 (Source)

소스 커넥터를 삭제하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

delete 하위 명령을 사용해요.

pulsar-admin sources delete options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

모든 Pulsar 소스 커넥터 삭제. 이 엔드포인트에 DELETE 요청을 보내요: DELETE /admin/v3/sources/{tenant}/{namespace}/{sourceName}

소스 커넥터 삭제.

void deleteSource(String tenant,
                  String namespace,
                  String source)
           throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | source | 소스 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException.PreconditionFailedException | 클러스터가 비어 있지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 deleteSource를 참고해요.

싱크 (Sink)

싱크 커넥터를 삭제하려면 다음 명령을 사용할 수 있어요.

  • Admin CLI
  • REST API
  • Java Admin API

delete 하위 명령을 사용해요.

pulsar-admin sinks delete options

최신·완전한 정보는 Pulsar admin docs를 참고해요.

싱크 커넥터 삭제. 이 엔드포인트에 DELETE 요청을 보내요: DELETE /admin/v3/sinks/{tenant}/{namespace}/{sinkName}

Pulsar 싱크 커넥터 삭제.

void deleteSink(String tenant,
                String namespace,
                String source)
         throws PulsarAdminException

파라미터 (Parameter)

| 이름 | 설명 | | tenant | 테넌트 이름 | | namespace | 네임스페이스 이름 | | sink | 싱크 이름 |

예외 (Exception)

| 이름 | 설명 | | PulsarAdminException.NotAuthorizedException | 관리 권한이 없음 | | PulsarAdminException.NotFoundException | 클러스터가 존재하지 않음 | | PulsarAdminException.PreconditionFailedException | 클러스터가 비어 있지 않음 | | PulsarAdminException | 예상치 못한 오류 |

자세한 내용은 deleteSource를 참고해요.

더 알아보기 (Learn more)