Re: reg kafka API versions

2017-10-20 Thread Ted Yu
See code in NetworkClient : int latestClientVersion = clientRequest .apiKey().latestVersion(); if (header.apiVersion() == latestClientVersion) { ... } else { log.debug("Using older server API v{} to send {} {} with correlation id {} to node {

reg kafka API versions

2017-10-20 Thread pravin kumar
I have run a Multiple Partition and Multiple Consumer application.Then i have altered the no of Partitions, in log im getting Using older server API v0 to send HEARTBEAT {group_id= altermultipartitionmulticonsumer2,group_generation_id=6, member_id=C2-b7b4f485-d0c3-466b-b0e7-b3de834832e9} to node