kora
kora copied to clipboard
@KafkaPublisher support for custom methods
Feature will allow users to create custom methods that are analogs to @KafkaListener ones but for producer
This will allow for easier use of @KafkaPubisher with ability to specify configuration path for topic in annotation on method to fix this producers method for declared topic only
@KafkaPublisher("test")
public interface TestProducer extends Producer<String,String> {
@KafkaPublisher.Topic("path.for.topic.in.config")
void send(String key, String value, Headers headers);
}