Class 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;
    • Constructor Detail

      • DumpAdminMessages

        public DumpAdminMessages()
    • Method Detail

      • getPubSubConsumerProperties

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