|
|
2 лет назад | |
|---|---|---|
| .. | ||
| etc | 871ee90b3e refactor(kafka_bridge): move kafka bridge into its own app | 2 лет назад |
| src | b089fba100 refactor: rm ee_bridge and ee_connector application | 2 лет назад |
| test | b089fba100 refactor: rm ee_bridge and ee_connector application | 2 лет назад |
| BSL.txt | 871ee90b3e refactor(kafka_bridge): move kafka bridge into its own app | 2 лет назад |
| README.md | 383fec9dfc docs: fix invalid links | 2 лет назад |
| docker-ct | 871ee90b3e refactor(kafka_bridge): move kafka bridge into its own app | 2 лет назад |
| rebar.config | 8430ec673c feat(kafka): check whether target topic exists | 2 лет назад |
This application houses the Kafka Producer and Consumer data integration bridges for EMQX Enterprise Edition. It provides the means to connect to Kafka and publish/consume messages to/from it.
Currently, our Kafka Producer library (wolff) has its own replayq
buffering implementation, so this bridge does not require buffer
workers from emqx_resource. It implements the connection management
and interaction without need for a separate connector app, since it's
not used by authentication and authorization applications.
For more information about Apache Kafka, please see its official site.
Please see Ingest Data into Kafka for more detailed info.
Please see our contributing.md.
EMQ Business Source License 1.1, refer to LICENSE.