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;

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DumpAdminMessages.AdminOperationInfo

Constructor Summary

Constructors

Constructor	Description
DumpAdminMessages()

Method Summary

Modifier and Type	Method	Description
static List<DumpAdminMessages.AdminOperationInfo>	dumpAdminMessages(PubSubConsumerAdapter consumer, String clusterName, long startingOffset, int messageCnt)
static Properties	getPubSubConsumerProperties(String kafkaUrl, Properties pubSubConsumerProperties)

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 List<DumpAdminMessages.AdminOperationInfo> dumpAdminMessages(PubSubConsumerAdapter consumer,
 String clusterName,
 long startingOffset,
 int messageCnt)

getPubSubConsumerProperties

public static Properties getPubSubConsumerProperties(String kafkaUrl,
 Properties pubSubConsumerProperties)