kazanzhy opened a new pull request, #23426: URL: https://github.com/apache/airflow/pull/23426
There is a high-level question about this integration. How to implement this hook? The first way is similar to PubSubHook when all functionality is in the hook. Like PubSubHook.publish(). The second way is similar to FirehoseHook when the hook is just a wrapper of the boto client which is used to interact with Kinesis. I think that the second way is preferable due to Pulsar client could reuse connections for producers and consumers -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
