Martin Gainty created KAFKA-4188:
------------------------------------

             Summary: compilation issues with 
org.apache.kafka.clients.consumer.internals.Fetcher.java
                 Key: KAFKA-4188
                 URL: https://issues.apache.org/jira/browse/KAFKA-4188
             Project: Kafka
          Issue Type: Bug
          Components: clients
    Affects Versions: 0.10.0.1
         Environment: Maven home: /maven325
Java version: 1.8.0_40, vendor: Oracle Corporation
            Reporter: Martin Gainty


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?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to