-
Notifications
You must be signed in to change notification settings - Fork 19
@KafkaPublisher support for custom methods #236
Copy link
Copy link
Open
Labels
Milestone
Description
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);
}