Смещение автоматической фиксации потока Kafka - PullRequest
Новая
       73

Смещение автоматической фиксации потока Kafka

0 голосов
/ 13 апреля 2020

Вот мой вопрос: My Top включает объединение, которое после некоторых процессоров и перед некоторыми другими процессорами, когда в процессорах после процессора объединения возникает необработанное исключение, закрывает целое потоковое приложение! Когда я перезапускаю приложение, обработка запускает узел соединения, а не начальный узел? Почему?

Ниже моя вершина: 

Topologies:
   Sub-topology: 0
    Source: KSTREAM-SOURCE-0000000000 (topics: [paymentReqTopic])
      --> assignId
    Processor: assignId (stores: [])
      --> qrCodeOrWithhold
      <-- KSTREAM-SOURCE-0000000000
    Processor: qrCodeOrWithhold (stores: [])
      --> qrCodeOrWithhold-predicate-0, qrCodeOrWithhold-predicate-1
      <-- assignId
    Processor: qrCodeOrWithhold-predicate-1 (stores: [])
      --> deduplicatePayment
      <-- qrCodeOrWithhold
    Processor: deduplicatePayment (stores: [paymentStore])
      --> KSTREAM-FILTER-0000000007
      <-- qrCodeOrWithhold-predicate-1
    Processor: KSTREAM-FILTER-0000000007 (stores: [])
      --> doPaymentWithProvider
      <-- deduplicatePayment
    Processor: doPaymentWithProvider (stores: [paymentStore])
      --> selectReqId
      <-- KSTREAM-FILTER-0000000007
    Processor: selectReqId (stores: [])
      --> KSTREAM-FILTER-0000000011
      <-- doPaymentWithProvider
    Processor: KSTREAM-FILTER-0000000011 (stores: [])
      --> KSTREAM-SINK-0000000010
      <-- selectReqId
    Sink: KSTREAM-SINK-0000000010 (topic: selectReqId-repartition)
      <-- KSTREAM-FILTER-0000000011
    Processor: qrCodeOrWithhold-predicate-0 (stores: [])
      --> none
      <-- qrCodeOrWithhold

  Sub-topology: 1
    Source: KSTREAM-SOURCE-0000000002 (topics: [paymentRespTopic])
      --> KSTREAM-WINDOWED-0000000014
    Source: KSTREAM-SOURCE-0000000012 (topics: [selectReqId-repartition])
      --> KSTREAM-WINDOWED-0000000013
    Processor: KSTREAM-WINDOWED-0000000013 (stores: [KSTREAM-JOINTHIS-0000000015-store])
      --> KSTREAM-JOINTHIS-0000000015
      <-- KSTREAM-SOURCE-0000000012
    Processor: KSTREAM-WINDOWED-0000000014 (stores: [KSTREAM-JOINOTHER-0000000016-store])
      --> KSTREAM-JOINOTHER-0000000016
      <-- KSTREAM-SOURCE-0000000002
    Processor: KSTREAM-JOINOTHER-0000000016 (stores: [KSTREAM-JOINTHIS-0000000015-store])
      --> KSTREAM-MERGE-0000000017
      <-- KSTREAM-WINDOWED-0000000014
    Processor: KSTREAM-JOINTHIS-0000000015 (stores: [KSTREAM-JOINOTHER-0000000016-store])
      --> KSTREAM-MERGE-0000000017
      <-- KSTREAM-WINDOWED-0000000013
    Processor: KSTREAM-MERGE-0000000017 (stores: [])
      --> KSTREAM-SINK-0000000018
      <-- KSTREAM-JOINTHIS-0000000015, KSTREAM-JOINOTHER-0000000016
    Sink: KSTREAM-SINK-0000000018 (topic: paymentTopic)
      <-- KSTREAM-MERGE-0000000017

, и когда make this comment

возникает исключение и закрывает мой поток, когда я перезапускаю свой поток, присоединяюсь к операции «повторить», а не к самому мощному процессору? почему

...