|
|
1 年之前 | |
|---|---|---|
| .. | ||
| src | d47cc0c367 feat: add max_linger_time and max_linger_bytes to Kafka producer | 1 年之前 |
| test | 4e0742c66f feat: make kafka producer freely dynamic | 1 年之前 |
| BSL.txt | 82403167c2 chore: update BSL license change date | 2 年之前 |
| README.md | 75ee3ced68 feat: add confluent connector/action | 2 年之前 |
| docker-ct | 69874b61f9 feat(krb): added test cases for kerberos authentication | 1 年之前 |
| mix.exs | f5bc4e6600 refactor(mix): move kafka dependencies to `UMP.common_dep` | 1 年之前 |
| rebar.config | 3ff0ed1fbc chore: upgrade to wolff-4.0.0 | 1 年之前 |
This application houses the Confluent Producer data integration bridge for EMQX Enterprise Edition. It provides the means to connect to Confluent Producer and publish messages to it via the Kafka protocol.
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 Kafka interface for Confluent, please see the official docs.
Please see Ingest Data into Confluent for more detailed info.
Please see our contributing.md.
EMQ Business Source License 1.1, refer to LICENSE.