Skip to content
Navigation Menu
Toggle navigation
Sign in
Appearance settings
Platform
GitHub Copilot
Write better code with AI
GitHub Spark
New
Build and deploy intelligent apps
GitHub Models
New
Manage and compare prompts
GitHub Advanced Security
Find and fix vulnerabilities
Actions
Automate any workflow
Codespaces
Instant dev environments
Issues
Plan and track work
Code Review
Manage code changes
Discussions
Collaborate outside of code
Code Search
Find more, search less
Explore
Why GitHub
Documentation
GitHub Skills
Blog
Integrations
GitHub Marketplace
MCP Registry
View all features
Solutions
By company size
Enterprises
Small and medium teams
Startups
Nonprofits
By use case
App Modernization
DevSecOps
DevOps
CI/CD
View all use cases
By industry
Healthcare
Financial services
Manufacturing
Government
View all industries
View all solutions
Resources
Topics
AI
DevOps
Security
Software Development
View all
Explore
Learning Pathways
Events & Webinars
Ebooks & Whitepapers
Customer Stories
Partners
Executive Insights
Open Source
GitHub Sponsors
Fund open source developers
The ReadME Project
GitHub community articles
Repositories
Topics
Trending
Collections
Enterprise
Enterprise platform
AI-powered developer platform
Available add-ons
GitHub Advanced Security
Enterprise-grade security features
Copilot for business
Enterprise-grade AI features
Premium Support
Enterprise-grade 24/7 support
Pricing
state:open label:enhancement
Search code, repositories, users, issues, pull requests...
Search syntax tips
Provide feedback
Saved searches
Use saved searches to filter your results more quickly
Sign in
Sign up
Appearance settings
Resetting focus
You signed in with another tab or window.
Reload
to refresh your session.
You signed out in another tab or window.
Reload
to refresh your session.
You switched accounts on another tab or window.
Reload
to refresh your session.
Dismiss alert
{{ message }}
fluent
/
fluent-plugin-kafka
Public
Notifications
You must be signed in to change notification settings
Fork
180
Star
308
Code
Issues
30
Pull requests
4
Actions
Projects
0
Wiki
Security
Uh oh!
There was an error while loading.
Please reload this page
.
Insights
Additional navigation options
Code
Issues
Pull requests
Actions
Projects
Wiki
Security
Insights
Issues
Search Issues
state
:
open
label
:
enhancement
state:open label:enhancement
Search
Labels
Milestones
New issue
Search results
Open
Closed
Fluentd configuration for enabling Ranger Authorization
enhancement
Feature request
Feature request
Status: Open.
#534
In fluent/fluent-plugin-kafka;
·
anupg336
opened
on Aug 22, 2025
Deprecate ruby-kafka version
enhancement
Feature request
Feature request
Status: Open.
#529
In fluent/fluent-plugin-kafka;
·
Watson1978
opened
on Mar 24, 2025
@username and @password are not present as config_param
enhancement
Feature request
Feature request
Status: Open.
#527
In fluent/fluent-plugin-kafka;
·
Gaurav-Puri101187
opened
on Feb 19, 2025
Add support for MSK IAM authentication in <code>rdkafka2</code> output type
enhancement
Feature request
Feature request
Status: Open.
#522
In fluent/fluent-plugin-kafka;
·
madebydna
opened
on Dec 2, 2024
Will there be support of any kind for Azure Event Hubs using Managed Identity?
enhancement
Feature request
Feature request
Status: Open.
#520
In fluent/fluent-plugin-kafka;
·
Idan37S
opened
on Nov 3, 2024
feat(out_waterdrop): add basic waterdrop output plugin
enhancement
Feature request
Feature request
Status: Open (in progress).
fluent/fluent-plugin-kafka
number 508
#508
In fluent/fluent-plugin-kafka;
·
raytung
opened
on Apr 1, 2024
ruby-kafka is no longer maintained and superseded by librdkafka via rdkafka-ruby bindings
enhancement
Feature request
Feature request
Status: Open.
#500
In fluent/fluent-plugin-kafka;
·
mensfeld
opened
on Nov 27, 2023
Support AWS MSK Authentication
enhancement
Feature request
Feature request
Status: Open.
#472
In fluent/fluent-plugin-kafka;
·
nonamef
opened
on Oct 25, 2022
Support for wildcard <code>topic_key</code>
enhancement
Feature request
Feature request
Status: Open.
#430
In fluent/fluent-plugin-kafka;
·
brsolomon-deloitte
opened
on Nov 3, 2021
How can I pass the password for the private key in the kafka_group input plugin.
enhancement
Feature request
Feature request
Status: Open.
#382
In fluent/fluent-plugin-kafka;
·
krylov-aleksandr
opened
on Dec 13, 2020
Timestamp is always parsed as local time
enhancement
Feature request
Feature request
Status: Open.
#377
In fluent/fluent-plugin-kafka;
·
wonnyz
opened
on Nov 11, 2020
Monitoring is not working with Kafka2 output plugin
enhancement
Feature request
Feature request
Status: Open.
#355
In fluent/fluent-plugin-kafka;
·
sreenuraghavan
opened
on Jul 30, 2020
You can’t perform that action at this time.