Kafka 연동 - SmartX-Team/Omniverse GitHub Wiki

! 해당 예제는 실습 환경에 따라 원할하게 진행되지 않을 수 있습니다.

해당 예제에서는 Kafka 메시지 브로커를 통해 외부 데이터 수신 후 Omniverse 상 prim 를 조작하는 Extension 를 생성하는 방법을 다루고 있습니다.

Extension Project 생성

KOSME Example 3 참조

1. 생성된 프로젝트의 config/extension.toml Open

[img1 : 생성된 프로젝트의 config/extension.toml Open ]

2. 필요한 파이썬 라이브러리 import

Omnivere Extension 에서 pip 등으로 설치가 필요한 파이썬 라이브러리 import 는 다음과 같이

extension.toml 파일에서 python.pipapi 를 정의후 필요한 라이브러리 목록을 입력합니다.

[img2 : config/extension.toml 에 필요한 라이브러리 입력 ]

3. 카프카 서버와 연동

카프카 서버는 현재 다음과 같은 주소에 임시로 준비해두었습니다. (PPT 페이지 참조)

토픽은 사용하고 계신 스트리밍 클라이언트 id 숫자에 맞춰 (KOSME:{id}) 를 사용하시면 됩니다. ex) 사용중인 클라이언트 id가 1 이면 KOSME1 Topic 사용

현재 카프카 토픽에는 가상의