添加新創建主題訂閱在反應卡夫

我開發反應卡夫卡在我們的遊戲斯卡拉項目，在我們創建的5個主題，由消費者團體訂閱和工作好，現在的問題是我創建了一個新的話題，如何我可以將此主題添加到現有的消費羣（是可能）我的代碼是：添加新創建主題訂閱在反應卡夫

val consumerSettings = ConsumerSettings(system, new ByteArrayDeserializer, new StringDeserializer) 
     .withBootstrapServers(bootStrapServer) 
     .withGroupId(groupId).withPollInterval(100 millis) 

    Consumer.committableSource(consumerSettings, Subscriptions.topics(topicList)) 
      .groupedWithin(10, 15 seconds) 
      .map({ 
       group => 
       var offSetBatch = CommittableOffsetBatch.empty 
       val sessionList = group.toList.map { eachItem => 
        offSetBatch = offSetBatch.updated(eachItem.committableOffset) 
        Json.parse(eachItem.record.value()).as[cityModel] 
       } 
       processRecords(cityList) 
       offSetBatch 
      }).mapAsync(1)(_.commitScaladsl()) 
      .toMat(Sink.ignore)(Keep.both) 
      .run()

有沒有什麼辦法，我可以在消費創建，我們可以給主題圖案添加話題消費者

來源

2017-03-22 kittu

i：e Subscriptions.topicPattern（「*。in」）將解決問題

來源

2017-04-19 17:26:27 kittu

添加新創建主題訂閱在反應卡夫

回答

相關問題