Class Heartbeat
java.lang.Object
org.apache.kafka.clients.consumer.internals.Heartbeat
A helper class for managing the heartbeat to the coordinator
-
Constructor Summary
ConstructorsConstructorDescriptionHeartbeat(org.apache.kafka.clients.GroupRebalanceConfig config, org.apache.kafka.common.utils.Time time) -
Method Summary
-
Constructor Details
-
Heartbeat
public Heartbeat(org.apache.kafka.clients.GroupRebalanceConfig config, org.apache.kafka.common.utils.Time time)
-
-
Method Details
-
poll
public void poll(long now)
-