|
|
1 vuosi sitten | |
|---|---|---|
| .. | ||
| etc | 871ee90b3e refactor(kafka_bridge): move kafka bridge into its own app | 2 vuotta sitten |
| src | 6891290469 fix(kafka consumer): ensure no repeated topics in the same connector | 1 vuosi sitten |
| test | 6891290469 fix(kafka consumer): ensure no repeated topics in the same connector | 1 vuosi sitten |
| BSL.txt | 82403167c2 chore: update BSL license change date | 2 vuotta sitten |
| README.md | 383fec9dfc docs: fix invalid links | 2 vuotta sitten |
| docker-ct | 69874b61f9 feat(krb): added test cases for kerberos authentication | 1 vuosi sitten |
| mix.exs | f5bc4e6600 refactor(mix): move kafka dependencies to `UMP.common_dep` | 1 vuosi sitten |
| rebar.config | aee67cc128 chore: bump brod -> 4.3.1 | 1 vuosi sitten |
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.