dev501

Results 2 issues of dev501

Description =========== 1. I am noticing the first call to ReadMessage never returns a message. Is this by design and always the case? If so, assuming the first read message...

Description =========== Do we have anything similar to the below in Go to get the endOffsets? **java** public Map endOffsets(Collection partitions) I was able to get the end offsets by...