Kafka Integration | Connection Managment

Not applicable

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

0 2 1,391
2 REPLIES 2

Not applicable

Not applicable

Since you are using the high level kafka producer api, it will take care of connection handling internally. I guess apigee has nothing to do with it. If same thing has to be done outside apigee, what would you do ? For me it looks like, kafka api take care of connection handling.