To use aerohive client you need a trusted HTTP server, Prozzie can’t provide you an HTTPS server, so you need an API-Gateway or reverse-proxy to forward HTTPS petitions to Aerohive client port.
traefikyou need configure
Let's Encryptcertificate and forward petitions to
Access Tokento verify the petitions.
You can run
prozzie config setup aerohive to interactively configure one aerohive connector. You will be asked for the next variables, that can’t have any default:
However, there are some others “hidden” variables that configure the connector. They will be output at the end of the interactive setup, and you can reuse them following the Advanced configuration.
To configure Aerohive you can use
# Connector's Name name=aerohive # Connector's Class connector.class=io.wizzie.kafka.connect.aerohive.WebhookSourceConnector # Max number of tasks (only 1 allowed) tasks.max=1 # Key converter to kafka key.converter=org.apache.kafka.connect.storage.StringConverter # Value converter to kafka value.converter=org.apache.kafka.connect.storage.StringConverter # Connector's client ID aerohive.client_id=aerohive-webhook # Aerohive Webhook token to verified requested data aerohive.access_token=aerohive_secret_access_token # Message processor message_processor_class=io.wizzie.kafka.connect.aerohive.processor.StringProcessor
You need to configure a
aerohive.properties file with your property:
When you configure the
aerohive.properties file you need to create the connector:
prozzie kcli create aerohive-connector < aerohive.properties
You can check that messages are properly delivered using
prozzie kafka consume <your-aerohive-topic>