KafkaConnector - new connector

[adrianfilip]

No description provided.

[tewecske]

I'm confused, zio-kafka already works with ZStream/ZPipline/Chunk.
What should this do?

[adrianfilip]

@tewecske
I was thinking of smth like this

trait KafkaConnector {

  def read(topic: => String): ZStream[Any, KafkaException, A]

}

package {
  def read(topic: => String): ZStream[KafkaConnector, KafkaException, A] = ???
}

case class LiveKafkaConnector(consumer: Consumer) implements KafkaConnector{
  ...
}