java擷取kafka consumer lag、endOffsets、beginningOffsets以及 KafkaConsumer總結

一、java擷取kafka consumer lag、endOffsets、beginningOffsets

maven依賴：

kafka-clients版本需要0.10.1.0以上，因為調用了新增接口endOffsets，lag=logsize-offset，logsize通過consumer的endOffsets接口獲得；offset通過consumer的committed接口獲得；

另外還可以通過AdminClient（官方），更多詳情可以參考 https://kafka.apache.org/documentation

　　

二、 org.apache.kafka.clients.consumer   Class KafkaConsumer<K,V> 總結

Package org.apache.kafka.clients.consumer (http://kafka.apache.org/20/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html)

java.lang.Object

org.apache.kafka.clients.consumer.KafkaConsumer<K,V>

<dl></dl>

<dt>All Implemented Interfaces:</dt>

<dd></dd>

<code>java.io.Closeable</code>, <code>java.lang.AutoCloseable</code>, <code>Consumer&lt;K,V&gt;</code>

作者的原創文章，轉載須注明出處。原創文章歸作者所有，歡迎轉載，但是保留版權。對于轉載了部落客的原創文章，不标注出處的，作者将依法追究版權，請尊重作者的成果。