emqx / emqx

82%

master: 82%

LAST BUILD ON BRANCH 20250203-r58-kafka-high-mem-drop

branch: 20250203-r58-kafka-high-mem-drop

CHANGE BRANCH

x

Reset

• 20250203-r58-kafka-high-mem-drop
• 0106-fix-mongodb-filters
• 0108-latency-metrics
• 0113-fix-rabbitmq-stop-timeout
• 0115-fix-default-auth
• 0120-remove-version-from-docker-compose
• 0121-limit-ee-uptime
• 0121-remove-redundant-retainer-enable-field
• 0124-extend-raw-authz-rules
• 0221-fix-shared-sub-stats
• 0225-fix-jwt-config-update-58
• 0225-refactor-limiter
• 0227-atomics-limiter
• 0303-fix-await-rel-expire-58
• 0616-try-not-to-exit-abnormal-as-much-as-possible
• 0618-ci-add-ecr-docker-push
• 1120-auth-cache
• 1121-rule-bridge-properties
• 1124-refactor-avoid-creating-atom-at-run
• 1128-chore-sync-release-branch-back-to-master
• 1206-refactor-shared-subs
• 1216-fix-EMQX-13521
• 1219-retainer-store-limiter
• 1220-fix-follow-14419
• 1230-refactor-shared-subs
• 20241206-r58-mysql-update
• 20241209-prep-5.8.4-alpha.1
• 20241209-r58-kconsu-pretty-hc-reason
• 20241209-sync-release-58
• 20241210-fix-ci-issues
• 20241210-r58-doc-listener-shutdown-limitation
• 20241210-r58-mqtt-bridge-custom-clientids
• 20241211-r58-fix-ds-msg-serializer-props
• 20241211-r58-test-flaky-listener
• 20241212-r58-kconsu-safe-topic-probe
• 20241217-r58-fix-iotdb-mix
• 20241217-r58-fix-rule-metrics-oos
• 20241217-r585-gprodu-pretty-error
• 20241217-r585-prometheus-mnesia-tm-broker-pool
• 20241218-r585-bridge-mqtt-user-props
• 20241218-r585-test-flaky-sqlserver
• 20241218-r585-test-warnings
• 20241219-ci-trigger-new-workflow
• 20241219-r585-ci-helm-test-port-fwd-loop
• 20241219-r585-fix-epgsql-datetime-crash
• 20241219-r585-mqtt-source-no-local
• 20241220-m-action-fallbacks
• 20250107-r58-data-export-api-nits
• 20250107-r58-fix-elixir-ots-erl-dep
• 20250108-m-ci-debug-helm-flakiness
• 20250108-m-refactorings-for-action-fallbacks
• 20250108-m-sync-r58
• 20250108-r58-action-source-summary-api
• 20250108-r58-refactorings-for-action-fallbacks
• 20250109-r58-async-connector-import
• 20250109-r58-fix-source-metrics-missing-on-load
• 20250110-r58-couchbase-msg-nit
• 20250113-m-upstream-session-state-mkII
• 20250114-r58-fix-mqtt-connector-reconnect
• 20250115-r58-fix-mqtt-source-shared-topic
• 20250116-m-ehttpc-max-inactive
• 20250116-m-sync-r58
• 20250116-r58-fix-internal-buffer-dropped-rule-metrics
• 20250116-r58-fix-s3-stop-pool
• 20250117-add-snap-package
• 20250117-r58-kprodu-overload-default
• 20250117-r58-summary-apis-nits
• 20250122-r58-ci-coveralls-retry-5xx
• 20250123-m-test-ds-integration-suite-skip
• 20250123-upstream-m-sync-r58
• 20250127-m-test-flaky-mgmt-import
• 20250127-m-test-flaky-ps
• 20250127-upstream-m-test-flaky-slow-conf-app
• 20250128-m-test-flaky-cluster-start-timeout
• 20250128-r58-fix-mt-sv-index-order
• 20250130-r58-alarm-rule-event
• 20250130-r58-kprodu-pprodu-lower-per-part-default
• 20250131-m-aggreg-json-lines
• 20250203-m-dash-default-password-file
• 20250203-m-deprecate-packets-publish-dropped
• 20250203-m-sync-r58
• 20250203-r58-ci-schema-registry-image
• 20250204-m-disk-log-action
• 20250205-m-defer-conf-backups
• 20250205-r58-extra-crl-logs
• 20250206-m-docs-fix-dropped-metrics-changelog
• 20250207-r58-docs-mqtt-conn-example-nit
• 20250207-r58-fix-bpapi-replicant-rejoin
• 20250207-r58-fix-flaky-ps-test
• 20250210-r58-mqtt-action-retry-when-tcp-closed
• 20250213-r58-data-export-filter-ctl
• 20250213-r58-fix-action-source-summary-enabled
• 20250213-r58-fix-alarm-events-rule-test
• 20250213-r58-fix-connector-api-update-validation-error-msg
• 20250213-r58-fix-mqtt-action-source-deps
• 20250214-r58-alarm-hook-async
• 20250214-r58-change-max-heap-size
• 20250214-r58-fix-rule-inc-inexistent-metric
• 20250214-r58-global-static-clientid-validation
• 20250217-m-sync-r58
• 20250217-r58-fix-async-add-remove-channel
• 20250217-r58-namespace-alarm-rule-events
• 20250217-r58-nit-fix-create-modify-dates
• 20250217-r58-nit-fix-create-modify-dates-mkII
• 20250218-bump-to-5.8.5-beta.1
• 20250218-r58-fix-connector-create-api-union
• 20250218-r58-mqtt-connector-connect-timeout
• 20250219-fix-quicer-macos-signing
• 20250219-r58-cli-data-export-print
• 20250219-r58-fix-gprodu-retry-normal
• 20250219-r58-nitty-max-heap
• 20250220-m-fix-async-add-remove-channel
• 20250220-m-sync-r58
• 20250220-m-sync-r58-b
• 20250220-r58-rule-last-modified-at
• 20250220-r58-sr-merge-import
• 20250221-bump-to-5.8.5-beta.2
• 20250221-m-sqlserver-named-instance
• 20250221-m-symlink-certs
• 20250224-bump-to-5.8.5-rc.1
• 20250224-m-fix-clients-v2-limit
• 20250224-m-nit-disabled-msg
• 20250225-m-fix-sync-bad-symlinks
• 20250226-m-mix-build-fixes
• 20250227-r58-fix-pulsar-oom-check
• 20250228-r58-plugin-install-secret
• 20250228-r59-sync-r58
• 20250303-update-codeowners
• 20250304-use-simpler-labels-in-ci
• 20250305-more-ci-fixes
• 20250305-r58-fix-test-sql-atom-keys
• 20250306-bump-builder-version
• 20250306-bump-to-5.8.6-alpha.1
• 20250306-r58-fix-download-backup-content-type
• 20250306-sync-master-to-release-59
• 20250307-r59-mt-limiter-mkII
• 20250310-r58-fix-jwks-tls-client-opts
• 20250310-r59-fix-event-type-rule-test
• 20250310-r59-sync-r58
• 20250311-bump-dashboard-version
• 20250311-fix-arm64-docker-image-upload
• 20250311-r58-new-mix-build-rm-logger
• 20250311-r58-new-mix-dialyzer
• 20250312-bump-to-5.9.0-beta.1
• 20250312-r58-test-flaky-conf-app-cluster
• 20250312-r58-test-flaky-crl-revoked
• 20250312-r58-test-flaky-shared-sub-gen-rpc
• 20250312-r59-sync-r58
• 20250313-r58-test-flaky-mqtt-v5-exit
• 20250313-r59-fix-resource-manager-update-channel
• 20250313-r59-mt-config-explicit
• 20250317-bump-emqx-enterprise-dashboard-version
• 20250317-bump-version-to-5.8.6-beta.1
• 20250317-r59-mt-limiter-followup
• 241118-totp
• 241119-ga-mt-m1-tns-to-clientid-index
• 241128-refine-config-docs
• 241209-log-dir-bad-path-fallback
• 241209-variform-undefined-as-empty-string
• 241212-max-packet-size-in-valid-range
• 241217-mute-unexpected-message-warning-log
• 241217-refine-evaluation-license-msg
• 250107-sync-release-58
• 250107-update-copyright-year
• 250108-refactor-emqx_broker_helper-no-need-to-keep-monitor-references
• 250109-refactor-emqx-cm-module-register-with-pid
• 250110-add-curl-to-docker-image
• 250110-refactor-emqx-cm-module-register-with-pid-for-5.8
• 250115-upgrade-wolff-4.0.5
• 250116-license-limit-count-sessions
• 250116-refactor-delete-sbom
• 250122-docs-fix-kakfa-produer-high-mem-threshold
• 250205-stomp-typos
• 250206-allow-reconnect-even-if-over-license-limit
• 250206-fix-stomp-heartbeat
• 250207-display-max_session-instead-of-max_connection-in-license-info-cli-output
• 250207-fix-max-packet-size-display
• 250208-allow-client-attributes-in-ACL-who-condition
• 250210-add-missing-change-logs
• 250213-remove-default-log-config-from-base.hocon
• 250214-improve-Kafka-connectivity-probe
• 250217-delayed-publish-interval-greater-than-max-int
• 250217-refine-pre-hook-auth-log
• 250218-docs-fix-api-doc-i18n
• 250218-refactor-simplify-auth-schema
• 250220-fix-config-update-performance-issue
• 250221-fix-doc-fomrat
• 250223-fix-license-doc
• 250223-fix-otel-config-url-default-value
• 250224-upgrade-kafka-producer-wolff-4.0.7
• 250225-fix-fmt
• 250226-smaller-build-matrix
• 250227-always-release-telemetry-app
• 250227-upgrade-pulsar-client
• 250228-add-trace-for-protocol-error
• 250228-refactor-max-connection-to-max-session
• 250228-throttle-qos0-message-drop-log
• 250301-new-license-type
• 250302-remove-fdb-build
• 250303-upgrade-mysql-driver
• 250305-add-evaluation-license
• 250305-sync-release-58-to-release-59
• 250306-cleanup-ce-ee-compile-flag
• 250306-upgrade-wolff-4.0.9
• 250311-merge-example-dirs
• 250313-delete-deprecated-config-schema
• 250314-add-listeners-root-doc
• 250317-improve-sqlserver-connector-healthcheck-failure-log-2
• 3.2.4
• 3.2.5
• 3.2.7
• 3.2.8
• 4.0-alpha.2
• 4.0-alpha.3
• 4.0-alpha.4
• 4.0-beta.1
• 4.0-beta.2
• 4.0-beta.3
• 4.0-beta.4
• 4.0-rc.1
• 4.0-rc.2
• 4.0-rc.3
• 4.0.0
• 4.0.1
• 4.0.2
• 4.0.3
• 4.0.4
• 4.0.5
• 4.0.6
• 4.0.7
• 4.04
• 50-ci-fix-self-hosted-macos-runners
• EMQX-2412-test-improve-emqx-connector-test-coverage-from-71-to-80
• EMQX-4203-delete-old-emqx-resource-instance-based-implementation
• EMQX-4204-auto-timer-based-retry-when-in-disconnected-state
• Fix-message-expiry-interval
• HEAD
• ResponseAndRequest
• Response＆Request
• add-cluster-name
• add-connected_at-into-disconnect-event
• add-jt808-example
• add-prop-into-sys-topic
• add_sockport_to_client_info
• add_sub_options
• add_sys_mon_case
• adopt-new-style
• alarm_and_monitor
• alarm_history
• anonymous_metric
• app_src
• auth_using_hooks
• avoid-needless-restart-gw-listeners
• backport/william-macos-quic-use-static-link
• baidian
• batch_delivery_config
• better-distclean
• better-ws-exit-mechanism
• bin_key_map
• bridge-disk-storage
• build-do-not-try-to-sign-quicer-binaries-on-macos
• build-fix-cross-build-packages-workflow
• build-respect-PKG_VSN-variable-in-rebar.config.erl
• build-use-realpath-in-emqx
• build-with-rebar3
• build/william/macos-quicer-no-dynlink-libcrypto
• bump-ehttpc-observer_cli
• bump-emqx-dashboard-version-20241224-033051
• bump-emqx-dashboard-version-20250224-074826
• bump-emqx-enterprise-dashboard-version-20241209-031201
• bump-emqx-enterprise-dashboard-version-20241210-101040
• bump-emqx-enterprise-dashboard-version-20241217-023354
• bump-emqx-enterprise-dashboard-version-20241219-092701
• bump-emqx-enterprise-dashboard-version-20241223-071335
• bump-emqx-enterprise-dashboard-version-20241224-060057
• bump-emqx-enterprise-dashboard-version-20250116-070015
• bump-emqx-enterprise-dashboard-version-20250217-094801
• bump-emqx-enterprise-dashboard-version-20250218-092520
• bump-emqx-enterprise-dashboard-version-20250221-021039
• bump-emqx-enterprise-dashboard-version-20250221-113913
• bump-emqx-enterprise-dashboard-version-20250224-074912
• bump-emqx-enterprise-dashboard-version-20250303-085814
• bump-emqx-enterprise-dashboard-version-20250317-064408
• caps
• cert_as_username
• channel-session-statem
• channel2
• channel3
• chore-build-with-rockylinux
• chore-reduce-docker-image-size
• chore-use-matrix-profile-when-building-elixir-images
• chore/EMQX-13447/bumps
• chore/EMQX-13447/otp-27-amqp
• chore/EMQX-13447/otp-27-builder
• chore/EMQX-13447/otp-27-part-ii
• chore/EMQX-13447/remnants
• chore/fix_iotdb_desc
• chore/iotdb_thrift_driver
• chore/refine-pbkdf2
• ci-add-codeball-auto-review
• ci-add-manual-workflow-to-upload-helm-charts
• ci-disable-docker-hub-description-update
• ci-fix-marketplace-workflow
• ci-notifications-on-scheduled-builds-failures
• ci-push-docker-images-at-tag
• ci/flaky-ds-raft-tc
• ci/flaky-ds-raft-tc-r58
• ci/flaky/utils-drain-down
• clear-to-pushgateway
• control-packets
• copy-of-master
• ct-mod-sup
• delay-receive
• delay_publish
• delete-bridge-functions
• dependabot/github_actions/actions-ad2a2e9744
• dependabot/github_actions/dot-github/actions/package-macos/actions-package-macos-d1ac57ba92
• dependabot/github_actions/dot-github/actions/prepare-jmeter/actions-prepare-jmeter-b5d68c1f0b
• dev-3.0
• dev-3.1
• dev/EMQX-14014-fix-mgmt-api-cluster
• dev/async-beamformer-handover
• dev/ee5.0
• dev/william/async-reply-session-takeover
• dev/william/emqx-fw
• dev/william/emqx_nft
• dev/william/feat-quic-sslkeylogfile
• dev/william/fix-emqtt-flaky
• dev/william/fix-olp-memory_protect_threshold
• dev/william/fix-quicer-listener-zone
• dev/william/lc-eks-mem-usage-reading
• dev/william/quic-abort-session
• dev/william/quicer-0.1.11
• dev/william/quicer-0.2.1
• develop-3.0
• develop-3.1
• develop-5
• discard_sess
• doc-for-http-connector
• docs-sync-russian-readme
• dup_flag
• e2e-minor-fix
• e3.0.0
• edge
• emq20
• emq22
• emqx30
• emqx30-deng
• emqx30-merge-misc-testcase
• emqx31
• emqx32
• emqx40
• enhance-flapping-detect-5
• enhanced_auth
• ensure-await-rel-timer
• ensure-disconnected
• ensure-expire-session-timer
• etcd_tls_config
• export_function
• expose-keepalive-api
• feat-e2e-authn-authz
• feat-otel-e2e-follow-traceparent
• feat-otel-e2e-trace-broker-publish-by-whitelist
• feat-rule-engine-e2e-trace
• feat-tdengine-new-auth-params
• feat/EMQX-13447/bump-hocon-etc
• feat/EMQX-13447/otp-27-gun-2
• feat/EMQX-13910/foolproof-cluster-leave
• feat/iotdb_batch
• feat/mfa
• feat/rulefunc
• fix-ci-for-master-branch
• fix-client-keepalive-bug
• fix-coverage-shaky
• fix-ct
• fix-docker-build-workflow
• fix-flapping
• fix-gateway-api-crash
• fix-gateway-listener-returns-404
• fix-listener-bind-fmt
• fix-monitory-rate
• fix-mqueue-fifo
• fix-oracle-testing-issue
• fix-otel-borker-publish-qos-override
• fix-otel-disconnect-events
• fix-otel-trace-qos-overide
• fix-plugin-cluster-sync
• fix-plugins-list-return
• fix-potential-bug
• fix-readme
• fix-rule-str-convert-func
• fix-session-case
• fix-shared-sub-typo-in-schema-file
• fix-sqlserver-utf16-little-encoding
• fix-strict-mode-check-dup
• fix-sys-mon-option
• fix-the-ignore-not-working
• fix-the-keepalive-return
• fix-unsuback-bug
• fix-ws-bug
• fix-ws-client-e2e-traces
• fix-ws-will
• fix/EMQX-11852/no-eager-cleanup-nodedown
• fix/EMQX-11852/purge-this-once
• fix/EMQX-13354/takeover-connack
• fix/EMQX-13447/jiffy
• fix/EMQX-13588/mria
• fix/EMQX-13886/robust-rebalance
• fix/EMQX-13886/robust-rebalance-next
• fix/EMQX-13939/failproof-clink-actor
• fix/GH-14541/prom
• fix/bridge_rab
• fix/exhook-clientinfo
• fix/exproto_host
• fix/iotdb_function_clause
• fix/iotdb_invalid_data
• fix/iotdb_payload
• fix/iotdb_schema
• fix/password_ts
• fix/william/flaky-quic-client-addr-change
• fix_345
• fix_bug
• fix_disconncet_pkt
• fix_json_encode
• fix_jt808_funcation_clause_error
• fix_log
• fix_return
• fix_sm_testcases
• fix_systopic_datetime
• fix_v3.4.4
• fix_will_msg
• fix_ws_reason
• fixes
• flapping
• for-emqx-v5.0
• function_clause_when_send_msg_to_bridges
• gh-readonly-queue/master/pr-9960-910731c0753ecf8223b25a9cab1db7e95bd288a2
• hiring
• hook-args
• hotfix
• hotfix_deliver_badmatch
• hotfix_for_3_1
• http_async
• id/ci-build-macos-arm64-release-packages
• improve-app-src
• improve-channel
• improve-channel-session
• improve-connect-pipeline
• improve-session-takeover
• improve_connect
• improve_coverage
• include-logger-hrl
• inline
• introduce-new-bridge-impl
• invalid_cpu_alarm
• issue#1972
• jt808-correct-type
• jt808-fix-error-docs
• jt808-send-default-authcode-in-anoynmous
• keepalive-docs
• kjellwinblad-patch-1
• load_plugins_explicitly
• logger_header
• main-v4.3
• main-v4.4
• max_subscriptions
• merge-local-and-mqtt-bridge
• merge-release-585-into-release-58
• modify_emqx_rpc
• more-gc-enforcement-policies
• more-params-for-log-traces
• move-delayed-publish-logic-to-emqx
• mqtt5-test-suite
• mqtt5_connack
• mqtt_bug
• mqtt_protocol_tests
• mqtt_tests
• msg_expiry_interval
• new-connection-module
• new-hooks
• nightly-3.0
• nightly-3.1
• nolocal-option-for-old-spec
• operational-behavior
• optimize-metrics-using-counters
• optimize-shared-sub
• optimize_log_conf
• oracle_health_check-58
• otel-e2e-trace-testcases
• per_group_sub5
• perf-config-changes
• pick-jt808-fixes-into-586-2
• pipeline
• plugins-on-config-changed
• prepare-584
• psk
• psk-suites
• recover-from-reload-slots-failure
• reduce-dep-size
• refactor-bridge
• refactor-new-bridge-impl-api
• refactor-portal-sup
• refactor/limiter
• release-3.0
• release-3.1
• release-3.2
• release-3.3
• release-4.0
• release-52
• release-53
• release-e501
• release-v5.0.5
• release-v5.0.7
• release-v5.0.8
• release-v50
• reliable_tracer
• remove-bad-logs-if-stomp-client-conn-failed
• remove-emqx-cli-module
• repeat_subscription
• retain_available
• reuse-plugin-filter-logic
• revert-14609-dev/william/fix-olp-memory_protect_threshold
• revert-1839-emqx30
• revert-2362-bin_key_map
• revert-8827-fix/sql_placeholder
• revert-relup-bump
• revert_binkey_map
• rewrite-mqueue
• rm-emqx-client-hrl
• rm_log_alarm
• rm_psk_tab
• route_batch_clean
• rpc_opts
• rule-engine
• separate_shared_and_non_shared_sub
• session-batch-delivery
• session_terminate
• shu-to-w
• shutdown-policy
• staled_session
• statem-channel
• strict-mode-frame
• subscription-sharding
• support-more-msg-types-in-log-throttling
• support-more-msgs-in-log-throttling
• support-placeholders-in-http-authz-authn
• switch_to_logger
• sync-release-58-20241210-023304
• sync-release-58-20241211-023219
• sync-release-58-20241211-151246
• sync-release-58-20241212-023229
• sync-release-58-20241213-023256
• sync-release-58-20241217-023215
• sync-release-58-20241218-023030
• sync-release-58-20250109-023845
• sync-release-58-20250113-023000
• sync-release-58-20250127-022611
• sync-release-58-20250128-022426
• sync-release-58-20250129-022411
• sync/250226/release-58
• sync/250226/release-58-master
• tablestore-fixes
• tablestore-integration-2
• test-tag
• truncat_log
• tune_global_gc
• tuning-io-polling
• ultimate-channel
• unload-emqx-alarm-handler-before-plugin-unload
• update_ehttpc-v5.0
• update_ekka
• update_topic_aliases
• v3.0-beta.3
• v3.0-beta.4
• v3.0-rc.1
• v3.0-rc.2
• v3.0-rc.3
• v3.0-rc.4
• v3.0-rc.5
• v3.0.0
• v3.0.1
• v3.1-beta.2
• v3.1-beta.3
• v3.1-beta1
• v3.1-rc.1
• v3.1-rc.2
• v3.1-rc.3
• v3.1.0
• v3.1.2
• v3.2-beta.2
• v3.2-beta.3
• v3.2-rc.1
• v3.2-rc.2
• v3.2-rc.3
• v3.2.0
• v3.2.1
• v3.2.2
• v3.2.3
• v3.2.4
• v3.2.5
• v3.2.6
• v3.2.7
• v3.2.8
• v3.3-alpha.1
• v3.4.0
• v3.4.1
• v3.4.2
• v3.4.3
• v3.4.4
• v3.4.5
• v3.4.6
• v3.4.7_client_id_unavailable
• v4.0-alpha.1
• v4.0-alpha.2
• v4.0-alpha.3
• v4.0-alpha.4
• v4.0-beta.1
• v4.0-beta.2
• v4.0-beta.3
• v4.0-beta.4
• v4.0-rc.1
• v4.0-rc.2
• v4.0-rc.3
• v4.0.0
• v4.0.1
• v4.0.10
• v4.0.2
• v4.0.3
• v4.0.4
• v4.0.5
• v4.0.6
• v4.0.7
• v4.0.8
• v4.04
• var_byte_int_v3.2.7
• var_byte_int_v3.4.5
• vm_args
• will_message
• win30
• workflow

Build # 13120649582

Build Type

Pull #14631

github

Committed by web-flow

Commit Message

Merge 3fc0ec4cf into 127b0fed8

Pull Request Pull Request #14631: fix(kafka producer): drop data more aggresively when under high memory stress

Run Details

57274 of 69572 relevant lines covered (82.32%)

15126.44 hits per line