Package com.linkedin.venice

Class DumpAdminMessages

java.lang.Object

com.linkedin.venice.DumpAdminMessages

public class DumpAdminMessages
extends java.lang.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 java.util.List<DumpAdminMessages.AdminOperationInfo>	dumpAdminMessages(PubSubConsumerAdapter consumer, java.lang.String clusterName, long startingOffset, int messageCnt)
static java.util.Properties	getPubSubConsumerProperties(java.lang.String kafkaUrl, java.util.Properties pubSubConsumerProperties)

Methods inherited from class java.lang.Object

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

Constructor Detail

DumpAdminMessages

public DumpAdminMessages()

Method Detail

dumpAdminMessages

public static java.util.List<DumpAdminMessages.AdminOperationInfo> dumpAdminMessages(PubSubConsumerAdapter consumer,
                                                                                     java.lang.String clusterName,
                                                                                     long startingOffset,
                                                                                     int messageCnt)

getPubSubConsumerProperties

public static java.util.Properties getPubSubConsumerProperties(java.lang.String kafkaUrl,
                                                               java.util.Properties pubSubConsumerProperties)