Package com.linkedin.venice

Class ControlMessageDumper

java.lang.Object

com.linkedin.venice.ControlMessageDumper

public class ControlMessageDumper
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
ControlMessageDumper(PubSubConsumerAdapter consumer, java.lang.String topic, int partitionNumber, int startingOffset, int messageCount)

Method Summary

Modifier and Type	Method	Description
int	display()	Display control messages from each producer
ControlMessageDumper	fetch()	1.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ControlMessageDumper

public ControlMessageDumper(PubSubConsumerAdapter consumer,
                            java.lang.String topic,
                            int partitionNumber,
                            int startingOffset,
                            int messageCount)

Method Detail

fetch

public ControlMessageDumper fetch()

1. Fetch up to messageCount messages in this partition. 2. Discard non-control messages. 3. Split into different groups based on producer

display

public int display()

Display control messages from each producer