kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [kafka] branch trunk updated: Minor: fix compilation error in KAFKA-6254
Date Tue, 06 Feb 2018 22:06:25 GMT
This is an automated email from the ASF dual-hosted git repository.

junrao pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new caf03d6  Minor: fix compilation error in KAFKA-6254
caf03d6 is described below

commit caf03d642b6992bf95b922f0cb5f724d265d4029
Author: Jun Rao <junrao@gmail.com>
AuthorDate: Tue Feb 6 14:04:46 2018 -0800

    Minor: fix compilation error in KAFKA-6254
---
 .../java/org/apache/kafka/clients/consumer/internals/FetcherTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
index e81e3d1..de621b4 100644
--- a/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
+++ b/clients/src/test/java/org/apache/kafka/clients/consumer/internals/FetcherTest.java
@@ -2183,7 +2183,7 @@ public class FetcherTest {
                                         long lastStableOffset, long logStartOffset, int throttleTime)
{
         Map<TopicPartition, FetchResponse.PartitionData> partitions = Collections.singletonMap(tp,
                 new FetchResponse.PartitionData(error, hw, lastStableOffset, logStartOffset,
null, records));
-        return new FetchResponse(new LinkedHashMap<>(partitions), throttleTime);
+        return new FetchResponse(Errors.NONE, new LinkedHashMap<>(partitions), throttleTime,
INVALID_SESSION_ID);
     }
 
     private MetadataResponse newMetadataResponse(String topic, Errors error) {

-- 
To stop receiving notification emails like this one, please contact
junrao@apache.org.

Mime
View raw message