Skip to content

Commit

Permalink
chore: Remove unused message in transactional producer (akka#1740)
Browse files Browse the repository at this point in the history
  • Loading branch information
johanandren authored May 7, 2024
1 parent 7f80ee2 commit ae2452a
Showing 1 changed file with 3 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,9 @@
package akka.kafka.internal

import akka.Done
import akka.actor.ActorRef
import akka.actor.Terminated
import akka.annotation.InternalApi
import akka.dispatch.{Dispatchers, ExecutionContexts}
import akka.dispatch.ExecutionContexts
import akka.kafka.ConsumerMessage.{GroupTopicPartition, PartitionOffsetCommittedMarker}
import akka.kafka.ProducerMessage.{Envelope, Results}
import akka.kafka.internal.DeferredProducer._
Expand All @@ -23,10 +22,10 @@ import org.apache.kafka.common.KafkaException
import org.apache.kafka.common.TopicPartition
import org.apache.kafka.common.errors.ProducerFencedException

import scala.concurrent.{Await, Future}
import scala.concurrent.Future
import scala.concurrent.duration._
import scala.collection.JavaConverters._
import scala.util.{Failure, Success, Try}
import scala.util.{Failure, Try}

/**
* INTERNAL API
Expand Down Expand Up @@ -96,10 +95,6 @@ private object TransactionalProducerStage {
}
}

final case class CommitTransaction(batch: NonemptyTransactionBatch,
beginNewTransaction: Boolean,
consumerGroupMetadata: ConsumerGroupMetadata)

}

/**
Expand Down

0 comments on commit ae2452a

Please sign in to comment.