org.apache.kafka.common.requests
Class HeartbeatRequest

java.lang.Object
  org.apache.kafka.common.requests.AbstractRequestResponse
      org.apache.kafka.common.requests.HeartbeatRequest

public class HeartbeatRequest
extends AbstractRequestResponse

Field Summary

static Schema

curSchema

Fields inherited from class org.apache.kafka.common.requests.AbstractRequestResponse

struct

Constructor Summary

HeartbeatRequest(java.lang.String groupId, int groupGenerationId, java.lang.String consumerId)

HeartbeatRequest(Struct struct)

Method Summary

java.lang.String	consumerId()
int	groupGenerationId()
java.lang.String	groupId()
static HeartbeatRequest	parse(java.nio.ByteBuffer buffer)

Methods inherited from class org.apache.kafka.common.requests.AbstractRequestResponse

equals, hashCode, sizeOf, toString, toStruct, writeTo

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

curSchema

public static Schema curSchema

Constructor Detail

HeartbeatRequest

public HeartbeatRequest(java.lang.String groupId,
                        int groupGenerationId,
                        java.lang.String consumerId)

HeartbeatRequest

public HeartbeatRequest(Struct struct)

Method Detail

groupId

public java.lang.String groupId()

groupGenerationId

public int groupGenerationId()

consumerId

public java.lang.String consumerId()

parse

public static HeartbeatRequest parse(java.nio.ByteBuffer buffer)