Skip to content

Commit

Permalink
make JournalPointer public
Browse files Browse the repository at this point in the history
  • Loading branch information
Denys Fakhritdinov committed Nov 14, 2024
1 parent 916090a commit 3480b68
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ package com.evolutiongaming.kafka.journal

import com.evolutiongaming.skafka.{Offset, Partition}

private[journal] final case class JournalPointer(partitionOffset: PartitionOffset, seqNr: SeqNr) {
final case class JournalPointer(partitionOffset: PartitionOffset, seqNr: SeqNr) {

def offset: Offset = partitionOffset.offset

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ import scala.concurrent.duration.FiniteDuration

/** Reader of the replicated journal (Cassandra by default).
*
* This allows to access the data replicated from Kafka to Cassandara. Note,
* This allows to access the data replicated from Kafka to Cassandra. Note,
* that all the methods of this class have eventual nature, i.e. there could be
* newer events already in Kafka, but not yet replicated to Cassandra.
*
Expand Down

0 comments on commit 3480b68

Please sign in to comment.