[kafka] branch 1.1 updated: HOTFIX: fix broken build

[mj...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/1.1 by this push:
     new 12fe337  HOTFIX: fix broken build
12fe337 is described below

commit 12fe33792c609978f0a4f739aac1b9428168cd0b
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Sat Oct 27 16:50:48 2018 -0700

    HOTFIX: fix broken build
---
 .../kafka/streams/state/internals/CachingKeyValueStoreTest.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
index ff4c583..d4978e6 100644
--- a/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/state/internals/CachingKeyValueStoreTest.java
@@ -107,8 +107,8 @@ public class CachingKeyValueStoreTest extends AbstractKeyValueStoreTest {
     public void shouldCloseAfterErrorWithFlush() {
         try {
             cache = EasyMock.niceMock(ThreadCache.class);
-            context = new InternalMockProcessorContext(null, null, null, (RecordCollector) null, cache);
-            context.setRecordContext(new ProcessorRecordContext(10, 0, 0, topic, null));
+            context = new MockProcessorContext(null, null, null, (RecordCollector) null, cache);
+            context.setRecordContext(new ProcessorRecordContext(10, 0, 0, topic));
             store.init(context, null);
             cache.flush("0_0-store");
             EasyMock.expectLastCall().andThrow(new NullPointerException("Simulating an error on flush"));