Zapan Gao and GitHub
abbd249c49
Adding support for specify input kafka offset for each partitions ( #1242 )
...
Adding a new flag `--input-kafka-offset` for supporting consumes from Kafka by specified offset.
2024-04-09 11:55:03 +03:00
Dima Golomozy and GitHub
40946831b9
goreplay-cli package ( #1148 )
...
change package from `main -> goreplay`
this will allow importing `goreplay` as a package
2023-01-12 18:24:45 +03:00
Urban Ishimwe
6d812ceb7f
changes plugins reader and writer method
...
// PluginReader is an interface for input plugins
type PluginReader interface {
PluginRead() (msg *Message, err error)
}
// PluginWriter is an interface for output plugins
type PluginWriter interface {
PluginWrite(msg *Message) (n int, err error)
}
2020-11-02 06:15:10 +02:00
David Fradin and GitHub
358cb78a53
Fix #835 : kafka bug ( #836 )
...
Correction of error introduce in PR #800
2020-10-19 10:56:07 +03:00
arijitad
80b19f918b
Map Appsetting to flag names.
2020-07-15 00:14:38 +05:30
田欧 and Leonid Bugaev
16b6a3cc31
Adjust package order ( #487 )
...
* format package order
* format package order
* format package order
* format package order and format code by fmt
2017-08-22 19:15:01 +05:00
Leonid Bugaev
e69570367b
More fmt fixes
2017-01-23 13:34:57 +03:00
Leonid Bugaev
5e90377a7f
Fmt changes
2017-01-20 21:01:19 +03:00
Leonid Bugaev
f520b338f3
Add tests and modify to work same as Kafka output
2017-01-20 21:00:23 +03:00
