같은 볼트에서 여러 HBase 테이블에 스톰 쓰기?

Question

나는 kafka 주제에서 데이터를 읽고 hbase 테이블에 저장하는 폭풍 토폴로지를 가지고 있는데, kafka 메시지의 데이터를 기반으로 메시지가 작성되는 테이블을 동적으로 결정하는 방법이 있는지 궁금합니다.

Answer 1

기본 HBase 볼트를 사용하고 있습니까?

여기에는 몇 가지 방법이 있습니다. 논리를 구현하는 볼트를 만들 수 있으며 다른 스트림에서 올바른 스트림을 구독하는 HBase 볼트를 사용하여 여러 스트림 중 하나에서 터플을 내보낼 수 있습니다. 논리가 매우 복잡하고이를 수행하는 데 필요한 볼트 수가 정상보다 많으면 테이블 선택 논리와 HBase 삽입을 모두 구현하는 볼트를 작성할 수 있습니다.