[KAFKA-4188] compilation issues with org.apache.kafka.clients.consumer.internals.Fetcher.java

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Cannot Reproduce
• Affects Version/s: 0.10.0.1
• Component/s: clients
• Environment: Maven home: /maven325; Java version: 1.8.0_40, vendor: Oracle Corporation
• Assignee: Unassigned
• Reporter: Martin Gainty
• Created: 17/Sep/16 14:36
• Updated: 01/Sep/17 05:26
• Resolved: 01/Sep/17 05:26

Description

from client module

org.apache.kafka.clients.consumer.internals.Fetcher.java wont compile here is one of the errors:

private PartitionRecords<K, V> parseFetchedData(CompletedFetch completedFetch) {

//later on highWatermark is referenced in partition and produces ERROR
this.sensors.recordsFetchLag.record(partition.highWatermark - record.offset());

/kafka/trunk/clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:[590,66] cannot find symbol
[ERROR] symbol: variable highWatermark

//assuming partition is TopicPartition partition I can correct by inserting :
public long highWatermark =0L; //into TopicPartition

is Fetcher.java producing correct behaviour?