org.apache.beam.sdk.io.kafka.jmh

Classes

• KafkaIOUtilsBenchmark
• KafkaIOUtilsBenchmark.AtomicAccumulatorState
• KafkaIOUtilsBenchmark.PlainAccumulatorState
• KafkaIOUtilsBenchmark.ProducerState
• KafkaIOUtilsBenchmark.VolatileAccumulatorState