Class

kafka.tools.ProducerPerformance

ProducerPerfConfig

Related Doc: package ProducerPerformance

Permalink

class ProducerPerfConfig extends PerfConfig

Linear Supertypes
PerfConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ProducerPerfConfig
  2. PerfConfig
  3. AnyRef
  4. Any
  1. Hide All
  2. Show all
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ProducerPerfConfig(args: Array[String])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. var batchSize: Int

    Permalink

  6. val batchSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink
    Definition Classes
    PerfConfig

  7. val brokerList: String

    Permalink

  8. val brokerListOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  9. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  10. val compressionCodec: CompressionCodec

    Permalink

  11. val compressionCodecOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink
    Definition Classes
    PerfConfig

  12. val csvMetricsReporterEnabled: Boolean

    Permalink

  13. val csvMetricsReporterEnabledOpt: OptionSpecBuilder

    Permalink

  14. val dateFormat: SimpleDateFormat

    Permalink

  15. val dateFormatOpt: ArgumentAcceptingOptionSpec[String]

    Permalink
    Definition Classes
    PerfConfig

  16. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  17. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  18. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  19. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  20. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  21. val helpOpt: OptionSpecBuilder

    Permalink
    Definition Classes
    PerfConfig

  22. val hideHeader: Boolean

    Permalink

  23. val hideHeaderOpt: OptionSpecBuilder

    Permalink
    Definition Classes
    PerfConfig

  24. var initialMessageId: Int

    Permalink

  25. val initialMessageIdOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  26. var isFixedSize: Boolean

    Permalink

  27. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  28. var isSync: Boolean

    Permalink

  29. val messageSendGapMs: Int

    Permalink

  30. val messageSendGapMsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  31. val messageSize: Int

    Permalink

  32. val messageSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink
    Definition Classes
    PerfConfig

  33. val metricsDirectoryOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  34. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  35. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  36. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  37. val numMessages: Long

    Permalink

  38. val numMessagesOpt: ArgumentAcceptingOptionSpec[Long]

    Permalink
    Definition Classes
    PerfConfig

  39. var numThreads: Int

    Permalink

  40. val numThreadsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  41. val options: OptionSet

    Permalink

  42. val parser: OptionParser

    Permalink
    Definition Classes
    PerfConfig

  43. val producerConfigOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  44. val producerNumRetries: Int

    Permalink

  45. val producerNumRetriesOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  46. val producerProps: Properties

    Permalink

  47. val producerRequestRequiredAcks: Int

    Permalink

  48. val producerRequestRequiredAcksOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  49. val producerRequestTimeoutMs: Int

    Permalink

  50. val producerRequestTimeoutMsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  51. val producerRetryBackOffMsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  52. val producerRetryBackoffMs: Int

    Permalink

  53. val reportingInterval: Int

    Permalink

  54. val reportingIntervalOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink
    Definition Classes
    PerfConfig

  55. val seqIdMode: Boolean

    Permalink

  56. val showDetailedStatsOpt: OptionSpecBuilder

    Permalink
    Definition Classes
    PerfConfig

  57. val syncOpt: OptionSpecBuilder

    Permalink

  58. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  59. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  60. val topics: Array[String]

    Permalink

  61. val topicsOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  62. val topicsStr: String

    Permalink

  63. val useNewProducer: Boolean

    Permalink

  64. val useNewProducerOpt: OptionSpecBuilder

    Permalink

  65. val varyMessageSizeOpt: OptionSpecBuilder

    Permalink

  66. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  67. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  68. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from PerfConfig

Inherited from AnyRef

Inherited from Any

Ungrouped