kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch trunk updated: HOTFIX: Fix compilation error in `ProducerStateManagerTest` (#6603)
Date Thu, 18 Apr 2019 16:39:04 GMT
This is an automated email from the ASF dual-hosted git repository.

jgus 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 7b4b298  HOTFIX: Fix compilation error in `ProducerStateManagerTest` (#6603)
7b4b298 is described below

commit 7b4b298edd02dc0313d655f94ef6670794ac24b2
Author: John Roesler <vvcephei@users.noreply.github.com>
AuthorDate: Thu Apr 18 11:38:54 2019 -0500

    HOTFIX: Fix compilation error in `ProducerStateManagerTest` (#6603)
    
    Reviewers: Jason Gustafson <jason@confluent.io>
---
 core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala b/core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala
index 2062fae..fe08a57 100644
--- a/core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala
+++ b/core/src/test/scala/unit/kafka/log/ProducerStateManagerTest.scala
@@ -226,7 +226,12 @@ class ProducerStateManagerTest extends JUnitSuite {
 
     def beginTxn(producerId: Long, startOffset: Long): Unit = {
       val relativeOffset = (startOffset - segmentBaseOffset).toInt
-      val producerAppendInfo = new ProducerAppendInfo(producerId, ProducerStateEntry.empty(producerId),
ValidationType.Full)
+      val producerAppendInfo = new ProducerAppendInfo(
+        partition,
+        producerId,
+        ProducerStateEntry.empty(producerId),
+        ValidationType.Full
+      )
       producerAppendInfo.append(producerEpoch, 0, 0, time.milliseconds(), startOffset, startOffset,
isTransactional = true)
       val logOffsetMetadata = LogOffsetMetadata(messageOffset = startOffset, segmentBaseOffset
= segmentBaseOffset,
         relativePositionInSegment = 50 * relativeOffset)


Mime
View raw message