Jack
Jack
In actual, AddFunc is just a wrapper for AddJob. AddJob will be invoked finnaly. So, If u wanna carry some params, u can use AddJob(), as @electricbubble provieds
Hi, it's most likely a problem with Kafka broker. Could you please try another Kafka tool such as the official Kafka shell tools to test your broker.
latest/oldest/integer both supported. see more at https://github.com/birdayz/kaf/pull/281
### normal case ### empty group case
Hi,it's a bug.I've added an error check and It's been merged. Could you please try it again with the latest version?
Negative lag mostly arises on the server side, such as when restarting Kafka incorrectly or having insufficient disk capacity. The root cause is that the consumer group's offset is lower...
Nice idea! We can implement it inside command "kaf topic describe"
Hey guys.It's been implemented, see more at https://github.com/birdayz/kaf/pull/279
Hi there. Perhaps it would be more appropriate to change the offset of your consumer group. Once you have reset the offset by timestamp, the group will begin consuming data...
@maowerner @birdayz FYI the following flags have been throughly tested. ``` --sasl-enable Connect using SASL --sasl-jaas-config-file string Location of JAAS config file with SASL username and password --sasl-method string SASL...