| Polina Koleva Version 0.0.5 of the kafka-cdi-extension is able to resolve simple expressions (e.g. "# {HOST} :# {PORT} "). Perhaps its a good idea to look at javax.el APIs for this. If so, let's create a new JIRA underneath this epic  BTW. w/ the version 0.0.5 it is also possible to receive key/value pairs in the consumer, like:
@Consumer(topic = "myTopic", groupId = "myGroupID") |
public void receiver(final String key, final String value) { |
logger.info("That's what I got: " + message); |
} |
|
|