Comments (4)
hey Nic!
the only reason (that i remember) why kt would hide an "offset" is that it comes back as the value that indicates that it wasn't marked yet (sarama.OffsetNewest, i think?). but i'm guessing your test rules that out?
did you test with different server versions vs sarama versions?
maybe the sarama consumer needs to be configured to that particular kafka server version?
should find some time in the next days to look a bit closer, but time and internet is still a bit rare at the moment.
from kt.
but i'm guessing your test rules that out?
Yup, that's not the case here.
did you test with different server versions vs sarama versions?
Tested with 0.10.0.1 and 0.10.1.0, latest Sarama
maybe the sarama consumer needs to be configured to that particular kafka server version?
I've tried that and it doesn't make a difference unfortunately.
Interestingly I just found out today that resetting the offset works for my group, even though it doesn't appear when listing groups!
from kt.
hey @nmaquet !
could you post (or email me privately) the result of
$ kt group -verbose -brokers some-broker -topic x -group y -version v0.10.0.1
$ kt group -verbose -brokers some-broker -topic x -group y -version v0.10.0.1 -reset 23
$ kt group -verbose -brokers some-broker -topic x -group y -version v0.10.0.1
? the commands failed for me when i didn't specify v0.10.0.1, but with a specified version i got the expected results. the -verbose
flag should help by printing out the sarama logs.
from kt.
hey @nmaquet again :)
i think you ran into (at least?) one of these issues:
- the version has a
v
prefix and quietly defaulted to the latest version when it didn't recognize the supplied version. - the offset for the group/topic combination that you shared wasn't set to an explicit value from what i could see, so sarama would identify it as OffsetNewest which kt in turn decided to hide from you. the reason for hiding was that you will get the -1 offset for pretty much any group/topic combination that has no explicit value.
i addressed both in #58: kt now provides feedback on supported kafka versions and doesn't hide the -1 one offsets.
could you run go get -u github.com/fgeller/kt
and test again? nb: current master also has same changes to the group
commands ui, -partition
is -partitions
now.
closing for now - please re-open if the issue isn't resolved after an update :)
from kt.
Related Issues (20)
- Latest release (v12.1.0) is 2.5 years old HOT 1
- Support SASL authentication HOT 1
- update topic
- Add -version command line option to indicate which version of kt is running
- Installation failure on Centos7 VM HOT 4
- improve certificates for system test HOT 1
- Add env KT_VERSION for -version
- kt group usability
- CRC didn't match HOT 3
- Feature request: Support parsing value as json HOT 2
- Can't use tk, after update macSO to Monterey HOT 3
- Seeing escape char, if producer from kotlin HOT 4
- Error || client has run out of available brokers HOT 2
- fatal error: runtime: bsdthread_register error HOT 2
- Quiet mode to avoid printing informational messages to stderr HOT 6
- Version string of v13.1.0 is still v13.0.0 HOT 1
- install from release tag v13.1.0 fails HOT 1
- Tolerate already existing topic
- set security.protocol to SASL_SSL??? HOT 1
- KT built for Win10/11 is possibly leaking memory HOT 3
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from kt.