update 更新日志，jdk编译版本

Author: jianx.cao001

code/kafka-java/pom.xml

@@ -14,8 +14,8 @@
 
  <properties>
  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
- <maven.compiler.source>1.7</maven.compiler.source>
- <maven.compiler.target>1.7</maven.compiler.target>
+ <maven.compiler.source>1.8</maven.compiler.source>
+ <maven.compiler.target>1.8</maven.compiler.target>
  </properties>
 
  <dependencies>

code/kafka-java/src/main/java/caojx/learn/consumer/MyConsumer.java

@@ -43,7 +43,7 @@ private static void generalConsumerAutoCommit() {
  //间隔100ms,拉取一次数据
  ConsumerRecords<String, String> records = consumer.poll(100);
  for (ConsumerRecord<String, String> record : records) {
- System.out.println(String.format("topic = %s, partition = %s, key = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
+ System.out.println(String.format("topic = %s, partition = %s, offset = %s, key = %s, value = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
  if (record.value().equals("done")) {
  flag = false;
  }
@@ -70,7 +70,7 @@ public static void generalConsumeMessageSyncCommit() {
  //间隔100ms,拉取一次数据
  ConsumerRecords<String, String> records = consumer.poll(100);
  for (ConsumerRecord<String, String> record : records) {
- System.out.println(String.format("topic = %s, partition = %s, key = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
+ System.out.println(String.format("topic = %s, partition = %s, offset = %s, key = %s, value = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
  if (record.value().equals("done")) {
  flag = false;
  }
@@ -99,7 +99,7 @@ private static void generalConsumeMessageAsyncCommit() {
  //间隔100ms,拉取一次数据
  ConsumerRecords<String, String> records = consumer.poll(100);
  for (ConsumerRecord<String, String> record : records) {
- System.out.println(String.format("topic = %s, partition = %s, key = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
+ System.out.println(String.format("topic = %s, partition = %s, offset = %s, key = %s, value = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
  if (record.value().equals("done")) {
  flag = false;
  }
@@ -124,7 +124,7 @@ public static void generalConsumeMessageAsyncCommitWithCallback() {
  //间隔100ms,拉取一次数据
  ConsumerRecords<String, String> records = consumer.poll(100);
  for (ConsumerRecord<String, String> record : records) {
- System.out.println(String.format("topic = %s, partition = %s, key = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
+ System.out.println(String.format("topic = %s, partition = %s, offset = %s, key = %s, value = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
  if (record.value().equals("done")) {
  flag = false;
  }
@@ -152,7 +152,7 @@ public static void mixSyncAndsyncCommit() {
  //间隔100ms,拉取一次数据
  ConsumerRecords<String, String> records = consumer.poll(100);
  for (ConsumerRecord<String, String> record : records) {
- System.out.println(String.format("topic = %s, partition = %s, key = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
+ System.out.println(String.format("topic = %s, partition = %s, offset = %s, key = %s, value = %s", record.topic(), record.partition(), record.offset(), record.key(), record.value()));
  }
  //异步提交
  consumer.commitAsync();

code/kafka-java/src/main/java/caojx/learn/partitioner/Custompartitioner.java

@@ -13,7 +13,7 @@
  * @author caojx
  * @version 1.0
  * @description 自定义分区分配器
- * @Copyright (c) 2018, Lianjia Group All Rights Reserved.
+ * @Copyright (c) 2018, xxx All Rights Reserved.
  * @date 2018-07-09
  */
 public class Custompartitioner implements Partitioner {