100644 blob 6543aad0e40fb83d13e90442aa0dcbaf8ab5cf63	KafkaData.java
100644 blob 6f1b5641d8757d9649a21dc6ad218b7157b64110	KafkaRecordsIterable.java
100644 blob fcf002b1dcc89121727a9ca28ab4887c4041959b	KafkaSource.java
100644 blob 0e9d750db88d3be8ef1696ad3ef6dd33f44b0cf3	KafkaUtils.java
040000 tree 007e27a2e948dd6a87d5af293a62c36eb0fa3fe1	inputformat
040000 tree a76867a8e3ed8ab9409191a22a04de676a76b942	offset
040000 tree 0dad57675a428a28478e00a6cf37febb64d3fb01	record