fluent / fluent/fluent-plugin-kafka

Feature Request - support with :trail

Open
#51 2 comments 0 reactions 0 assignees View on GitHub
enhancement
Dominant language
Ruby
Stars
307
Forks
178
Avg merge
10h 37m
Merged PRs (30d)
13

Description

Hi there,
I see there is a parameter `options[:trail]` right here in [ConsumerGroup](https://github.com/bsm/poseidon_cluster/blob/17f372ff2c351841f84eecd88774785386f244b5/lib/poseidon/consumer_group.rb#L94). Which is used to skip all the old messages in a specific topic. It's very useful if you want to consume an existing topic from the latest.

I would like to have it supported here in fluent plugin.

Contributor guide

No contributing guide indexed for this repository

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.