That seems not possible even using ShellSpout/ShellBolt directly, since
there's no way to pass metrics to register. I tracked the history, and
registering method was there but got removed long time ago.
If we can define the way correctly, Flux might be able to register metrics
too.
Seems like we
Hello, I'd like to understand difference between auto commit mode
true/false in new KafkaSpout.
With auto.commit.enabled = false KafkaSpout will move my offset relying on
acked tuples, it seems easy.
But what happens if I turn auto commit on?
How Kafka make decision which offset to commit?
Hello,
you might notice the below email is a simplified repost as the last one got no
attention which may have been because it was in a wrong thread. Sorry about
that, but any answer from a reliable source qualifies - even "nobody knows
anymore" or "not sure, please file a Jira with a minimal
