0 / 0
영어 버전 문서로 돌아가기
Apache Kafka 연결
마지막 업데이트 날짜: 2024년 11월 28일
Apache Kafka 연결

Apache Kafka로 데이터에 액세스하려면 해당 데이터에 대한 연결 자산을 작성하십시오.

Apache Kafka는 분산 이벤트 스트리밍 플랫폼입니다. Apache Kafka 실시간 처리 서버에 연결하여 항목을 작성하고 주제에서 이벤트 스트림을 읽을 수 있습니다.

지원되는 버전

Apache Kafka 버전 0.11 - 2.x

Apache Kafka에 대한 연결 작성

연결 자산을 작성하려면 다음 연결 세부사항이 필요합니다.

Kafka 서버 호스트 이름: Kafka 서버의 호스트 이름 및 포트 번호입니다. hostname:port-number형식을 사용하십시오. Kafka 클러스터에 연결하려면 값을 쉼표로 구분하십시오 ( hostname1:port-number1,hostname2:port-number2,hostname3:port-number3). 클러스터에 연결하는 경우, 연결은 부트스트랩을 위해 지정되는 서버에 관계없이 모든 서버를 사용합니다. 이러한 서버는 동적으로 변경할 수 있는 전체 클러스터 멤버십을 발견하기 위한 초기 연결에 사용되므로 이 목록은 전체 서버 세트를 포함할 필요가 없습니다. 그러나 Kafka 클러스터에 세 개 이하의 호스트가 있는 경우 데이터 유실을 방지하기 위해 이 목록에 모든 호스트를 포함시키십시오.

보안 연결

Kafka 서버에 설정된 네트워크 인증 프로토콜을 선택하십시오. 없음 이 기본값입니다. 다음은 기타 선택사항 및 해당 특성입니다.

SASL OAUTHBEARER

OAuth 2.0 을 선택하십시오.

  • 서버 URL: 토큰 엔드포인트 URL입니다. 예: https://example.com/oauth2/default/v1/token.
  • 클라이언트 ID: OAuth 클라이언트 ID입니다.
  • 클라이언트 시크릿: OAuth 클라이언트 시크릿
  • 범위 OAuth 서버에 대한 호출에서 참조할 선택적 범위입니다.
  • 추가 특성: 추가 OAuth 구성 옵션입니다. key=value 쌍으로 입력하십시오. 이 다중 행 특성의 값은 Java 특성 클래스 요구사항을 준수해야 합니다.
  • 신뢰 저장소 인증서: PEM 형식의 신뢰할 수 있는 인증서. X.509 인증서만 지원됩니다.

SASL_Plain

사용자 프린시펄 이름: Kafka 서버 또는 클러스터에서 인증된 사용자입니다.

비밀번호: 사용자 프린시펄 이름의 비밀번호입니다.

SASL_SSL

사용자 프린시펄 이름: Kafka 서버 또는 클러스터에서 인증된 사용자입니다.

비밀번호: 사용자 프린시펄 이름의 비밀번호입니다.

신뢰 저장소 인증서: PEM 형식의 신뢰 저장소 인증서. X.509 인증서만 지원됩니다.

SCRAM-SHA-256 또는 SCRAM-SHA-512

사용자 프린시펄 이름: Kafka 서버 또는 클러스터에서 인증된 사용자입니다.

비밀번호: 사용자 프린시펄 이름의 비밀번호입니다.

신뢰 저장소 인증서: PEM 형식의 신뢰 저장소 인증서. X.509 인증서만 지원됩니다.

SSL

신뢰 저장소 인증서: PEM 형식의 신뢰 저장소 인증서. X.509 인증서만 지원됩니다.

키: PEM 형식의 개인 키입니다. 키는 PKCS #8 구문을 사용해야 합니다.

키 인증서 체인: PEM 형식의 개인 키에 대한 인증서 체인입니다. X.509 인증서만 지원됩니다.

키 비밀번호: 이 값은 키가 암호화된 경우에 필요합니다.

메시지 형식

스키마 레지스트리는 메시지를 관리하고 스키마를 토픽에 맵핑하는 써드파티 소프트웨어입니다. 이를 통해 생성자는 어떤 토픽이 어떤 유형 (스키마) 의 메시지를 승인하는지 알 수 있고 이용자는 토픽에서 메시지를 읽고 구문 분석하는 방법을 알 수 있습니다. 메시지 형식에 스키마 레지스트리 사용을 선택하면 이러한 추가 세부사항을 선택하여 스키마 레지스트리 서비스에 안전하게 연결할 수 있습니다.

전제조건

Confluent (Confluent 버전 6.x 및 7.x 지원) 또는 IBM Event Streams Kafka 서버의 스키마 레지스트리를 설정하세요.

스키마 레지스트리 URL: 스키마 레지스트리 서비스에 대한 URL입니다.

인증

스키마 레지스트리 서비스에 대한 인증 메소드를 선택하십시오. 없음 이 기본값입니다. 다음은 기타 선택사항 및 해당 특성입니다.

  • Kafka 서버 SASL 사용자 신임 정보 사용: Kafka 서버에 대한 보안 연결을 위해 SASL_Plain 또는 SASL_SSL 에 대한 특성을 입력한 경우 이 선택사항을 선택할 수 있습니다. SASL 보안 설정의 사용자 이름 및 비밀번호는 스키마 레지스트리 서비스에 대한 인증에 사용됩니다.

  • 사용자 신임 정보: 스키마 레지스트리 서비스에 대한 사용자 이름 및 비밀번호입니다.

보안 연결

스키마 레지스트리 서비스에 대한 보안 네트워크 인증 프로토콜을 선택하십시오. 없음 이 기본값입니다. 다음은 기타 선택사항 및 해당 특성입니다.

  • Kafka 서버 SSL 사용자 신임 정보 사용: Kafka 서버에 대한 보안 연결을 위해 SSL 의 특성을 입력한 경우 이 선택사항을 선택할 수 있습니다. Kafka 서버 연결의 인증서 구성은 스키마 레지스트리 서비스에 대한 보안 연결에 사용됩니다.

  • SSL

    • 신뢰 저장소 인증서: PEM 형식의 신뢰 저장소 인증서. X.509 인증서만 지원됩니다.
    • 키: PEM 형식의 개인 키입니다. 키는 PKCS #8 구문을 사용해야 합니다.
    • 키 인증서 체인: PEM 형식의 개인 키에 대한 인증서 체인입니다. X.509 인증서만 지원됩니다.
    • 키 비밀번호: 이 값은 키가 암호화된 경우에 필요합니다.

스키마 레지스트리 유형

스키마 레지스트리 유형을 선택합니다:

  • Confluent
  • IBM Event Streams(Confluent - 호환 가능 API)

플랫폼에 있는 위치를 기반으로 연결을 작성하는 방법 선택

프로젝트에서
자산 > 새 자산 > 데이터 소스에 연결을 클릭하십시오. 프로젝트에 연결 추가를 참조하십시오.

카탈로그에서
카탈로그에 추가 > 연결을 클릭하십시오. 카탈로그에 연결 자산 추가를 참조하십시오.

Platform assets catalog
새 연결을 클릭하십시오. 플랫폼 연결 추가를 참조하십시오.

다음 단계: 연결에서 데이터 자산 추가

이 연결의 사용처

다음 작업 공간 및 도구에서 Apache Kafka 연결을 사용할 수 있습니다.

프로젝트

Catalogs

  • Platform assets catalog

  • 기타 카탈로그(IBM Knowledge Catalog)

    참고:

    미리보기, 프로필 및 마스킹은 IBM Knowledge Catalog에서 이 연결에 대해 인증되지 않았습니다.

Apache Kafka 설정

자세한 정보

상위 주제: 지원되는 연결

일반적인 AI 검색 및 응답
이러한 응답은 제품 문서의 컨텐츠를 기반으로 하는 watsonx.ai 의 대형 언어 모델에 의해 생성됩니다. 자세히 알아보기