卡夫卡8.2.2動態主題下降的第一個事件

編輯：我看到同樣的確切行爲與卡夫卡9消費者API也。卡夫卡8.2.2動態主題下降的第一個事件

我有一個簡單Kafaka 8.2.2生產者設置爲true啓用主題產生財產。當創建具有不存在主題的事件時，它會創建一個新主題，但創建該主題的事件不會以Kafka結尾，並且返回的RecordMetadata沒有錯誤。

public void receiveEvent(@RequestBody EventWrapper events) throws InterruptedException, ExecutionException, TimeoutException { 
    log.info("Sending " + events.getEvents().size() + " Events "); 
    for (Event event : events.getEvents()) { 
     log.info("Sending Event - " + event); 
     ProducerRecord<String, String> record = new ProducerRecord<>(event.getTopic(), event.getData()); 

     Future<RecordMetadata> ack = eventProducer.send(record); 
     log.info("ACK - " + ack.get()); 
    } 

    log.info("SENT!"); 
}

我有一個新的話題投票（我不開心與卡夫卡8動態/正則表達式的話題碼），並發現新的隊列和訂閱程序，它也看到隨後發生的事件，但從來沒有那第一個事件

我也嘗試了卡夫卡的控制檯消費者腳本，它會看到完全一樣的。第一個事件從未見過，然後事件開始流動。

想法？

來源

2016-02-16 Gandalf

原來你可以設置一個屬性props.put（「auto.offset.reset」，「earliest」）;

和設置在此之後，消費者不會接受把關於這個專題的第一次活動。

來源

2016-02-19 00:22:51 Gandalf

卡夫卡8.2.2動態主題下降的第一個事件

回答

相關問題