We have written a custom java code for Kafka Integration and used it in postflow as fire and forget. It is bassically for the purpose of sending logs to kafka queue so that it can be consumed by any of the applications for further processing.
I just to want to understand here how APIGEE is working with connection management to Kafka cluster IPs(Not a Http Interface). Are we creating a new connection every time a API request is invoked?
Also if it is the case, is there any way we can create a connection once and just use producer.send method to push messages everytime we get a API request.
Please let me know if any more deatils are needed.kafka-integration.zip
LinkedIn
Twitter
