at 6:46 PM, Piotr Husiatyński p...@optiopay.com wrote:
I'm using Go with kafka library** and sending fetch request as
described in wire protocol documentation returns messages off by one.
Are you sure that code that you wrote is not sending fetch request
with offset being one less than you pass
khangaon...@gmail.com wrote:
Hi,
I suspect If some message from the given offset have expired, then they
will not be returned.
regards
On Tue, Apr 21, 2015 at 5:14 AM, Piotr Husiatyński p...@optiopay.com wrote:
According to documentation, sending fetch request with offset value
result
According to documentation, sending fetch request with offset value
result in messages starting with given offset (including) and greater.
https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchAPI
Logically one specifies the topics,
Sorry if this mail is not send properly, but I have no idea how to
send in gmail response to mailing list without having original message
in mailbox.
How does it compare to Sarama?
There are several important differences. It's been about two months
since I looked at sarama API and I know that
Hi,
I'm writing new client library for kafka and I cannot find information about
atomicity of message set publishing. I'm implementing protocol described on
wiki [1]. According to documentation, it is possible to send within single
request more than one message - message set for any partition.
In
