Package io.confluent.kafka.schemaregistry.tools

Class SchemaRegistryClientPerformance

java.lang.Object

io.confluent.common.utils.AbstractPerformanceTest

io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance

io.confluent.kafka.schemaregistry.tools.SchemaRegistryClientPerformance

public class SchemaRegistryClientPerformance
extends SchemaRegistryPerformance

Field Summary

Fields inherited from class io.confluent.common.utils.AbstractPerformanceTest

stats, targetIterationRate

Constructor Summary

Constructors

Constructor	Description
SchemaRegistryClientPerformance(String baseUrl, String subject, long numSchemas, long targetSchemasPerSec, String schemaType)

Method Summary

Modifier and Type	Method	Description
protected void	close()
protected void	doIteration(io.confluent.common.utils.PerformanceStats.Callback cb)
protected void	init()
static void	main(String[] args)

Methods inherited from class io.confluent.kafka.schemaregistry.tools.SchemaRegistryPerformance

finished, makeParsedSchema, makeSchema, runningFast

Methods inherited from class io.confluent.common.utils.AbstractPerformanceTest

getTargetIterationRate, run, run

Methods inherited from class java.lang.Object

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

Constructor Details

SchemaRegistryClientPerformance

public SchemaRegistryClientPerformance(String baseUrl,
 String subject,
 long numSchemas,
 long targetSchemasPerSec,
 String schemaType)

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

init

protected void init()
             throws Exception

Overrides:

init in class SchemaRegistryPerformance

Throws:

Exception

doIteration

protected void doIteration(io.confluent.common.utils.PerformanceStats.Callback cb)

Overrides:

doIteration in class SchemaRegistryPerformance

close

protected void close()
              throws IOException

Overrides:

close in class SchemaRegistryPerformance

Throws:

IOException