akka-persistence-kafka writes journal and snapshot entries to Kafka.
- Java:
1.8+ - Scala:
2.11.xor2.12.xor2.13.x - Akka:
2.5.x(Scala 2.11 only),2.6.x(Scala 2.12, 2.13) - Kafka
2.4.x+ - Alpakka-Kafka
2.0.x+.
Add the following to your sbt build (2.11.x, 2.12.x, 2.13.x):
resolvers += "Sonatype OSS Release Repository" at "https://oss.sonatype.org/content/repositories/releases/"
val version = "..."
libraryDependencies += Seq(
"com.github.j5ik2o" %% "akka-persistence-kafka" % version
)The minimum necessary settings are as follows.
# if use journal plugin
akka.persistence.journal.plugin = "j5ik2o.kafka-journal"
# if use snapshot plugin
akka.persistence.snapshot-store.plugin = "j5ik2o.kafka-snapshot-store"
j5ik2o {
kafka-journal {
topic-prefix = "journal-"
# if need customize, default is persistence-id
topic-resolver-class-name = "com.github.j5ik2o.akka.persistence.kafka.resolver.KafkaTopicResolver$PersistenceId"
# if need customize, default is partion 0
partition-resolver-class-name = "com.github.j5ik2o.akka.persistence.kafka.resolver.KafkaPartitionResolver$PartitionZero"
producer {
kafka-clients {
bootstrap.servers = "localhost:6001"
}
}
consumer {
kafka-clients {
bootstrap.servers = "localhost:6001"
group.id = "akka-persistence-journal"
}
}
}
kafka-snapshot-store {
topic-prefix = "snapshot-"
# if need customize, default is persistence-id
topic-resolver-class-name = "com.github.j5ik2o.akka.persistence.kafka.resolver.KafkaTopicResolver$PersistenceId"
# if need customize, default is partition 0
partition-resolver-class-name = "com.github.j5ik2o.akka.persistence.kafka.resolver.KafkaPartitionResolver$PartitionZero"
producer {
kafka-clients {
bootstrap.servers = "localhost:6001"
}
}
consumer {
kafka-clients {
bootstrap.servers = "localhost:6001"
group.id = "akka-persistence-snapshot"
}
}
}
}
