Package com.linkedin.venice

Class DumpAdminMessages

java.lang.Object

com.linkedin.venice.DumpAdminMessages

public class DumpAdminMessages
extends Object

The design consideration to consume in admin tool directly instead of letting controller to consume the required admin message and return them back to admin tool: 1. Controller may not have all the latest schemas for AdminOperation, then controller couldn't print human-readable string for unknown admin operations; 2. Don't introduce any overhead to controller since sometimes controller itself is already very slow;

Constructor Summary

Constructors

Constructor	Description
DumpAdminMessages()

Method Summary

Modifier and Type	Method	Description
static int	dumpAdminMessages(PubSubConsumerAdapter consumer, String clusterName, PubSubPosition startingPosition, int messageCnt)	Dumps admin messages from the admin topic for the given cluster.

Methods inherited from class java.lang.Object

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

Constructor Details

DumpAdminMessages

public DumpAdminMessages()

Method Details

dumpAdminMessages

public static int dumpAdminMessages(PubSubConsumerAdapter consumer,
 String clusterName,
 PubSubPosition startingPosition,
 int messageCnt)

Dumps admin messages from the admin topic for the given cluster. Messages are logged as they are received instead of being buffered.

Parameters:

consumer - the PubSub consumer to use

clusterName - the name of the cluster

startingPosition - the starting position to consume from

messageCnt - the maximum number of messages to consume

Returns:

the number of messages processed