File tree Expand file tree Collapse file tree
persistence-kafka/src/main/scala/com/evolutiongaming/kafka/flow/kafkapersistence Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -2,7 +2,7 @@ import Dependencies.*
22
33ThisBuild / versionScheme := Some (" early-semver" )
44ThisBuild / evictionErrorLevel := Level .Warn
5- ThisBuild / versionPolicyIntention := Compatibility .BinaryCompatible
5+ ThisBuild / versionPolicyIntention := Compatibility .None
66
77lazy val Scala3Version = " 3.3.5"
88lazy val Scala2Version = " 2.13.16"
Original file line number Diff line number Diff line change @@ -5,9 +5,9 @@ import org.apache.kafka.clients.producer.internals.BuiltInPartitioner
55
66/** Maps partitions of source Kafka topics into persistence topics.
77 *
8- * Please be careful when using this with [[ com.evolutiongaming.kafka.flow.RemapKey ]] . Only the identity mapper is
8+ * Please be careful when using this with ` com.evolutiongaming.kafka.flow.RemapKey` . Only the identity mapper is
99 * guaranteed to work properly with an arbitrary `RemapKey`, for other combinations you have to manually ensure that
10- * the [[ isStateKeyOwned ]] implementation is correct and will not allow duplicate KeyFlows.
10+ * the ` isStateKeyOwned` implementation is correct and will not allow duplicate KeyFlows.
1111 *
1212 * If the aggregate key depends on the record's contents, then only the identity mapper can be used.
1313 */
@@ -22,7 +22,7 @@ trait KafkaPersistencePartitionMapper {
2222 def getStatePartition (sourcePartition : Partition ): Partition
2323
2424 /** Checks if the aggregate in the state partition should be initialized as a
25- * [[ com.evolutiongaming.kafka.flow.KeyFlow ]] .
25+ * ` com.evolutiongaming.kafka.flow.KeyFlow` .
2626 *
2727 * If the aggregate is initialized, it will have timers and ticks started. This is not desirable if the aggregate is
2828 * actually sourced from a different partition, which will also be started concurrently.
You can’t perform that action at this time.
0 commit comments