[kafka] branch 2.4 updated: MINOR: fix typo in TestInputTopic.getTimestampAndAdvance (#7553)

[mjsax]

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

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


The following commit(s) were added to refs/heads/2.4 by this push:
     new 9c3082e  MINOR: fix typo in TestInputTopic.getTimestampAndAdvance 
(#7553)
9c3082e is described below

commit 9c3082e6e2867fa56a9613faf1f22fcc9bd41234
Author: A. Sophie Blee-Goldman <sop...@confluent.io>
AuthorDate: Fri Oct 18 16:23:33 2019 -0700

    MINOR: fix typo in TestInputTopic.getTimestampAndAdvance (#7553)
    
    Reviewers: Bill Bejeck <b...@confluent.io>, John Roesler 
<j...@confluent.io>, Matthias J. Sax <matth...@confluent.io>
---
 .../src/main/java/org/apache/kafka/streams/TestInputTopic.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java
index 50310aa..c5966a7 100644
--- 
a/streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java
+++ 
b/streams/test-utils/src/main/java/org/apache/kafka/streams/TestInputTopic.java
@@ -97,7 +97,7 @@ public class TestInputTopic<K, V> {
         currentTime = currentTime.plus(advance);
     }
 
-    private Instant getTimestampAndAdvanced() {
+    private Instant getTimestampAndAdvance() {
         final Instant timestamp = currentTime;
         currentTime = currentTime.plus(advanceDuration);
         return timestamp;
@@ -111,7 +111,7 @@ public class TestInputTopic<K, V> {
      */
     public void pipeInput(final TestRecord<K, V> record) {
         //if record timestamp not set get timestamp and advance
-        final Instant timestamp = (record.getRecordTime() == null) ? 
getTimestampAndAdvanced() : record.getRecordTime();
+        final Instant timestamp = (record.getRecordTime() == null) ? 
getTimestampAndAdvance() : record.getRecordTime();
         driver.pipeRecord(topic, record, keySerializer, valueSerializer, 
timestamp);
     }