Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to stream. This will handle al

Constructor based on a JAAS configuration. <p>For digest, you should have a pair of user name and password defined in this figgure.

Constructor to put all items in ClusterSummary in MetricSet as a metric. All metrics are derived from a cached ClusterSummary object, expired {@link C

Kafka metadata.

Create a manager with the given context.

Creates a new CommonKafkaSpoutConfig using a Builder. @param builder The Builder to construct the CommonKafkaSpoutConfig from

Create a new component. @param type the type of component this is @param compId the id of the component @param execs the executors for this compon