THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
public interface ResponseInfo { /* @return a map of error to its count of occurrence. */ public Map<Errors, Integer> getErrorCounts(); /* This method should only be invoked if the response is of type ApiKeys.FETCH. Otherwise, an exception is thrown. * @return a map of topic partition to the datanumber of bytes that isare fetched from this topic partition. */ public Map<TopicPartition, FetchResponse.PartitionData>Long> getFetchResponseDatagetFetchFromTopicPartitionSizeInBytes(); } |
This interface defines the methods that can be used in the client's implementation of the observer to extract information from the response.
...