apache-storm

0열

1답변

나는 메시지를 다시 처리 할 수있는 횟수를 설정하기 위해 SpoutConfig에 retryLimit이 있음을 알고 있습니다. retryLimit에 대해서는 이 내가 SpoutConfig.class에있는 메시지는 다음과 같습니다 지수 백 오프 설정을 다시 시도하십시오. 이들은 에 의해 사용됩니다. 이 OutputCollector.fail()을 호출 한 후 메

1열

1답변

WSO2 CEP Siddhi의 단일 인스턴스에서 여러 개의 코어를 사용할 수 있습니까?

8 코어가있는 Linux 컴퓨터에서 실행되는 WSO2 CEP의 인스턴스가 있습니다. 거의 200 개의 실행 계획이있는 30-40 개의 입력 스트림이 있습니다. 내 문제는 이벤트를 삽입 할 때 한 번에 하나의 CPU 만 사용 중입니다. 바쁜 핵심 변경 사항이지만 동시에 성능과 확장성에 영향을 미치는 8 개의 코어를 동시에 작동시킬 수는 없습니다. 누락 된 구

0열

1답변

Apache Storm의 여러 볼트와 동일한 클래스 사용

Apache Storm을 처음 사용하고 여러 개의 볼트 용량 문제가 발생했습니다. 그래서 볼트으로 사용되는 클래스 X이 있습니다. builder.setBolt(BOLT-1, new X()); builder.setBolt(BOLT-2, new X()); builder.setBolt(BOLT-3, new X()); 볼트 위의 각 별도의 홈통에 바인딩 :

0열

1답변

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

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

0열

1답변

apache-storm이 akka와 같은 우선 순위 사서함을 제공합니까?

설명 : docs에서 설명했듯이 akka는 다른 유형보다 먼저 일부 유형의 메시지를 처리하려는 경우에 도움이되는 우선 순위 사서함을 제공합니다. 폭풍 문서에서 유사한 기능을 찾지 못했습니다. 비슷한 지원이 apache-storm에서 사용 가능합니까? 아니면 비슷한 동작이 어떻게 이루어질 수 있습니까?

0열

1답변

폭풍 토폴로지의 한 볼트에서 더 많은 튜플을 수신하는 것을 중지하는 방법

스톰 토폴로지 중 하나에서 유스 케이스를 사용하여 처리를 위해 볼트로 들어가는 튜플 수를 제어하려고합니다. 예를 들어, 100 개의 튜플이 이미 처리되고있는 경우 더 많은 튜플을받는 것을 중단하고 싶습니다. 아마 이것은 topology.max.spout.pending에 의해 제어 될 수 있지만,이 구성은 토폴로지 레벨에 있습니다. 어떻게 볼트 레벨에서이 작

0열

1답변

kafkabolt를 사용하여 폭풍 botl의 결과를 kafka 중개인에게 어떻게 내 보낼 수 있습니까?

나는 폭풍우에서 wordcount 예제를 변경하려고합니다. 결과를 표시하는 대신 카프카 클러스터에 보내고 싶습니다. 당신이 볼 수 있듯이, 나는 카프카 주제에 wordcounter 볼트의 결과를 보낼 Config config = new Config(); config.setDebug(true); config.put(Config.TOPOLOG

0열

1답변

는 실행 StormId 아파치 스톰

에 이름을 기반으로하는 방법을 어떻게 아파치 폭풍에 이름에 따라 현재 실행중인 폭풍 IDS를 얻을 수 있습니다.

0열

1답변

Apache flume과 Apache storm의 차이점은 무엇입니까?

Apache flume과 Apache storm의 차이점은 무엇입니까? 폭풍우를 사용하여 로그 데이터를 Hadoop 클러스터로 가져올 수 있습니까? 두 가지 모두 스트리밍 데이터로 사용되므로 폭풍을 flume 대신 사용할 수 있습니까? 아파치 수로는 스트리밍 많은 양의 데이터를 수집하기위한 서비스입니다

0열

1답변

Apache Storm 로그를 STDOUT으로 리디렉션

Apache Storm이 STDOUT에 로그를 기록하도록 할 수 있습니까? 작업자 및 클러스터 XML 파일에서 일부 구성을 볼 수 있지만 STDOUT으로 리디렉션하는 것이 기본적으로 또는 일부 조정이 필요한지 확실하지 않습니다.