2017-10-27 5 views
0

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

답변

3

아니요. 스톰은 내가 알고있는 한이 점이 없습니다. 메시지는 볼트에 도착한 순서대로 처리됩니다.

이 기능이 실제로 필요한 경우이 효과를 얻으려면 두 구성에서 토폴로지를 두 번 제출하는 것이 가장 좋습니다. 낮은 우선 순위 메시지를 읽는 메시지와 높은 우선 순위 메시지 만 읽는 메시지입니다. 튜플 스트림을 하나의 토폴로지에서 우선 순위가 낮은 메시지와 우선 순위가 높은 메시지로 나눌 수는 있지만, 우선 순위가 낮은 메시지의 간섭을 여전히 볼 수 있습니다. topology.max.spout.pending.