ets)
which, of course, would require a bit more bookkeeping of what was the last
processed offset for each partition of each topic in the current set of records.
Or, perhaps this example should be reworked to not be committing offsets until
after it has processed all the records?
---
Richard
version to remain compatible during the bounce.
This is done using the inter.broker.protocol.version property. More on that
topic can be read here:
https://kafka.apache.org/083/documentation.html#upgrade
Hopefully that helps clear things up.
Thank you,
Grant
On Thu, Oct 1, 2015 at 12:21 PM,
Note the 0.8.3-SNAPSHOT has recently been renamed 0.9.0.0-SNAPSHOT.
In any event, the major version number change could indicate that there
has, in fact, been some sort of incompatible change. Using 0.9.0.0, I'm
also unable to use the kafka-console-consumer.sh to read from a 0.8.2.1
broker, b
It appears from maven central and git that there was a 0.8.2.2 release
on Sept 2nd. However, the Kafka downloads page
(https://kafka.apache.org/downloads.html) does not appear to have been
updated.
Also, why aren't the kafka shell scripts made available as a .tgz file
in maven central like t
Hi there-
The error message returned when trying to produce to a nonexistent kafka topic
(with auto topic creation disabled) is non obvious. It returns an error
message of the form:
"org.apache.kafka.common.errors.TimeoutException: Failed to update metadata
after xx ms"
where xx is a small n
