emqx/apps/emqx_bridge_kafka/src
Thales Macedo Garitezi 9c3f838e14
Merge pull request #10841 from thalesmg/kafka-validate-key-v50
feat({kafka,pulsar}_producer): add validation for empty message key when strategy = key_dispatch
2023-05-30 09:37:15 -03:00
..
emqx_bridge_kafka.app.src feat(kafka_producer): add validation for empty message key when strategy = key_dispatch 2023-05-26 12:02:58 -03:00
emqx_bridge_kafka.erl feat(kafka_producer): add validation for empty message key when strategy = key_dispatch 2023-05-26 12:02:58 -03:00
emqx_bridge_kafka_consumer_sup.erl refactor(kafka_bridge): move kafka bridge into its own app 2023-04-12 13:54:45 -03:00
emqx_bridge_kafka_impl.erl refactor(kafka_bridge): move kafka bridge into its own app 2023-04-12 13:54:45 -03:00
emqx_bridge_kafka_impl_consumer.erl fix(kafka): improve shutdown and health check logs during shutdown 2023-05-25 16:38:09 -03:00
emqx_bridge_kafka_impl_producer.erl feat(kafka): ensure allocated resources are removed on failures 2023-05-25 16:38:09 -03:00