File tree Expand file tree Collapse file tree 2 files changed +3
-2
lines changed
core/src/main/scala/com/evolutiongaming/kafka/flow/kafka
persistence-cassandra/src/main/scala/com/evolutiongaming/kafka/flow/cassandra Expand file tree Collapse file tree 2 files changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -60,7 +60,6 @@ object KafkaModule {
6060
6161 def healthCheck = _healthCheck
6262
63-
6463 def consumerOf = { (groupId : String ) =>
6564 LogResource [F ](KafkaModule .getClass, s " Consumer( $groupId) " ) *>
6665 _consumerOf[String , ByteVector ](
Original file line number Diff line number Diff line change @@ -58,7 +58,9 @@ private[flow] object CassandraCodecs {
5858 }
5959 }
6060
61- implicit val encodeByNamePartition : EncodeByName [Partition ] = EncodeByName [Int ].contramap { (a : Partition ) => a.value }
61+ implicit val encodeByNamePartition : EncodeByName [Partition ] = EncodeByName [Int ].contramap { (a : Partition ) =>
62+ a.value
63+ }
6264
6365 implicit val decodeByNamePartition : DecodeByName [Partition ] = DecodeByName [Int ].map { a => Partition .of[Try ](a).get }
6466
You can’t perform that action at this time.
0 commit comments