kafka的groupid

設置消費者properties的兩個參數 consumer.group.id properties.setProperty("auto.offset.reset", "earliest」) // latest 注意： 只要不更改group.id，每次重新消費kafka，都是從上次消費結束的地方繼續開始，不論"auto.offset.reset」屬性設置的是什麼   場景一：Kafka上在實時被灌入

>>阅读原文<<