再看 Kafka Lag

在《Kafka的Lag計算誤區及正確實現》一文中說起了kafka.admin.ConsumerGroupCommand.PartitionAssignmentState沒法被外部訪問，故要將PartitionAssignmentState前的protected修飾符去掉

能夠直接將describeGroup返回的結果轉換成JSON而後傳至監控頁面（supported by YANGliiN oba）。代碼以下：

String[] agrs = {"--describe", "--bootstrap-server", brokers, "--group", groupId};
ConsumerGroupCommand.ConsumerGroupCommandOptions options =
        new ConsumerGroupCommand.ConsumerGroupCommandOptions(agrs);
ConsumerGroupCommand.KafkaConsumerGroupService kafkaConsumerGroupService =
        new ConsumerGroupCommand.KafkaConsumerGroupService(options);
ObjectMapper mapper = new ObjectMapper();
//1. 使用jackson-module-scala_2.12
mapper.registerModule(new DefaultScalaModule());
//2. 反序列化時忽略對象不存在的屬性
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
//3. 將Scala對象序列化成JSON字符串
String source = mapper.writeValueAsString(kafkaConsumerGroupService.describeGroup()._2.get());
複製代碼

這裏須要採用的是jackson-module-scala的包實現，若是直接用普通的JSON序列化方式那麼會達不到想要的效果，jackson以及jackson-module-scala對應的Maven庫以下：

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-core</artifactId>
    <version>2.9.4</version>
</dependency>
<dependency>
    <groupId>com.fasterxml.jackson.module</groupId>
    <artifactId>jackson-module-scala_2.12</artifactId>
    <version>2.9.5</version>
</dependency>
複製代碼

注意若是本地安裝的Scala版本與所配置的jackson-module-scala版本不一致的話會報出一些異常。發散一下思惟：既然能夠序列化爲JSON，那麼徹底能夠經過JSON再反序列化會對象，只不過經過JSON做爲中間媒介，將訪問受限的Scala對象轉變爲Java對象，上面剩餘代碼以下：

//4. 將JSON字符串反序列化成Java對象
List<PartitionAssignmentState> target = mapper.readValue(source,
        getCollectionType(mapper,List.class,PartitionAssignmentState.class));
//5. 排序
target.sort((o1, o2) -> o1.getPartition() - o2.getPartition());
//6. 打印
printPasList(target);
複製代碼

如此就能夠達到與前面幾篇文章中關於獲取消費者詳情功能一樣的效果。這裏有兩個注意要點：

1. PartitionAssignmentState中的coordinator是Node類型，這個類型須要自定義，Kafka原生的會報錯。
2. 反序列化時Node會有一個empty的屬性不識別，解決方案參考代碼中的步驟2.

代碼更多細節請參考：代碼

經過JSON的序列化和反序列化操做實現了本來不能爲之的事情，那麼思惟再發散一下，也能夠序列化成字節流，好比經過ByteBuffer進行轉換，只不過編程邏輯變得複雜了。

上面這段陳述有可能會讓人以爲Scala與Java之間的互操做起來不容易，其實否則，上面這段陳述只是用來補充一下如何獲取消費者詳情的另外一種方法，Scala與Java之間的互操做仍是比較簡單的，通常狀況下均可以直接使用對方的類。對於集合而言，Scala中還有用於Scala與Java集合的互轉的scala.collection.JavaConverters（scala2.8.1開始引入），與此雷同的scala.collection.JavaConversions已被標註爲@Deprecated（since 2.12.0）。在scala代碼中若是須要集合轉換，首先引入scala.collection.JavaConverters._，進而顯示調用asJava或者asScala方法完成轉型。關於Scala與Java集合互轉的介紹會在下一篇文章中呈現。