Skip to content
#

fs2

Here are 164 public repositories matching this topic...

vlovgr
vlovgr commented Oct 11, 2019

Similarly to #234, it would be useful to provide functions for creating test KafkaProducers.

A good first function would be one which yields somewhat sensible default RecordMetadata.

object KafkaProducer {
  def unit[F[_], K, V](implicit F: Sync[F]): F[KafkaProducer[F, K, V]] = ???
}

Likely, this would require some internal state, hence F[KafkaProducer[F, K, V]].

Improve this page

Add a description, image, and links to the fs2 topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the fs2 topic, visit your repo's landing page and select "manage topics."

Learn more