Skip to content

feat(mqtt_consumer): omit retained messages - #20084

Open
MrS-E wants to merge 6 commits into
influxdata:masterfrom
MrS-E:feature/10824-ignore-retained-messages
Open

MrS-E wants to merge 6 commits into
influxdata:masterfrom
MrS-E:feature/10824-ignore-retained-messages

Conversation

@MrS-E

@MrS-E MrS-E commented Nov 6, 2026

Copy link
Copy Markdown

Summary

Adds the bool option omit_retained, when set to true, retained messages are not processed.

I ran into the problem of having Telegraf execute commands directly on boot because of retained messages (and having messages twice in the DB). I cannot make the messages not-retain because of clients that can connect and need that data.

While searching for a solution, I came across the old PR #7177 (and the issue #10824) and used it as baseline for this one. The solution is from #7177. I cherry-picked the commits and adjusted them to the new structure and modified the docs further. The added tests are AI code.

Checklist

Related issues

resolves #10824

@telegraf-tiger

telegraf-tiger Bot commented Nov 6, 2026

Copy link
Copy Markdown
Contributor

Thanks so much for the pull request!
🤝 ✒️ Just a reminder that the CLA has not yet been signed, and we'll need it before merging. Please sign the CLA when you get a chance, then post a comment here saying !signed-cla

@telegraf-tiger telegraf-tiger Bot added the feat Improvement on an existing feature such as adding a new setting/mode to an existing plugin label Nov 6, 2026
@MrS-E

MrS-E commented Nov 6, 2026

Copy link
Copy Markdown
Author

!signed-cla

@telegraf-tiger

telegraf-tiger Bot commented Nov 6, 2026

Copy link
Copy Markdown
Contributor

Download PR build artifacts for linux_amd64.tar.gz, darwin_arm64.tar.gz, and windows_amd64.zip.
Downloads for additional architectures and packages are available below.

⚠️ This pull request increases the Telegraf binary size by 6.82 % for linux amd64 (new size: 329.3 MB, nightly size 308.2 MB)

📦 Click here to get additional PR build artifacts

Artifact URLs

. DEB . RPM . TAR . GZ . ZIP
amd64.deb aarch64.rpm darwin_amd64.tar.gz windows_amd64.zip
arm64.deb armel.rpm darwin_arm64.tar.gz windows_arm64.zip
armel.deb armv6hl.rpm freebsd_amd64.tar.gz windows_i386.zip
armhf.deb i386.rpm freebsd_armv7.tar.gz
i386.deb ppc64le.rpm freebsd_i386.tar.gz
mips.deb riscv64.rpm linux_amd64.tar.gz
mipsel.deb s390x.rpm linux_arm64.tar.gz
ppc64el.deb x86_64.rpm linux_armel.tar.gz
riscv64.deb linux_armhf.tar.gz
s390x.deb linux_i386.tar.gz
linux_mips.tar.gz
linux_mipsel.tar.gz
linux_ppc64le.tar.gz
linux_riscv64.tar.gz
linux_s390x.tar.gz

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

feat Improvement on an existing feature such as adding a new setting/mode to an existing plugin

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Feature request for mqtt_consumer: ignore retained messages

2 participants