Processor annotation

[FPerezP]

We want to have a new set of annotations for Kafka processors. It means that annotating a @free trait or abstract class adding the @processor annotation, we will have 2 more available to label our methods:

@publisher: will generate code to allow publishing messages to a specific topic
@subscriber: will start consuming messages.

Example:

  object processor {

    @free
    @processor
    trait FreesKafkaProcessor {

      @publisher("topic") def objectDispatcher(): FS[Unit]
      @subscriber[String, String]("topic") def objectFetcher(): FS[Unit]
    }
  }

[raulraja]

I think that we can get around with just @publisher and @subscriber which I would call @producer and @consumer if instead of being annotations over def they are over an object or class that is path dependent to the FreesKafkaProcessor or whatever algebra the user is located in.