스크립트 개발 / 커넥터 객체 DFF.CONN / Kafka

Kafka 커넥터 작업 객체는 주로 Kafka를 조작하는 몇 가지 메서드를 제공합니다.

DFF.CONN(...) 매개변수는 다음과 같습니다:

매개변수	유형	필수 / 기본값	설명
connector_id	str	필수	커넥터 ID

메시지 구독

커넥터에서 메시지 구독에 관한 내용은 스크립트 개발 / 커넥터 구독을 참조하십시오.

.publish(...)

메시지를 발행하고 Kafka가 전송 결과를 확인할 때까지 대기합니다. 매개변수는 다음과 같습니다:

매개변수	유형	필수 / 기본값	설명
topic	str	필수	토픽
message	str/bytes	필수	메시지 내용; 문자열은 UTF-8로 인코딩됩니다

kafka.publish(topic='events', message='hello')

전송에 성공하면 None을 반환하며, 연결 또는 전송에 실패하면 예외가 발생합니다.