kafka.tools.ProducerPerformance

ProducerPerfConfig

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
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

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

Value Members

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

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

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

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. var batchSize: Int

  8. val batchSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Definition Classes
    PerfConfig

  9. val brokerList: String

  10. val brokerListOpt: ArgumentAcceptingOptionSpec[String]

  11. def clone(): AnyRef

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

  12. val compressionCodec: CompressionCodec

  13. val compressionCodecOpt: ArgumentAcceptingOptionSpec[Integer]

    Definition Classes
    PerfConfig

  14. val csvMetricsReporterEnabled: Boolean

  15. val csvMetricsReporterEnabledOpt: OptionSpecBuilder

  16. val dateFormat: SimpleDateFormat

  17. val dateFormatOpt: ArgumentAcceptingOptionSpec[String]

    Definition Classes
    PerfConfig

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

    Definition Classes
    AnyRef

  19. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  20. def finalize(): Unit

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

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

    Definition Classes
    AnyRef → Any

  22. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  23. val helpOpt: OptionSpecBuilder

    Definition Classes
    PerfConfig

  24. val hideHeader: Boolean

  25. val hideHeaderOpt: OptionSpecBuilder

    Definition Classes
    PerfConfig

  26. var initialMessageId: Int

  27. val initialMessageIdOpt: ArgumentAcceptingOptionSpec[Integer]

  28. var isFixedSize: Boolean

  29. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  30. var isSync: Boolean

  31. val messageSendGapMs: Int

  32. val messageSendGapMsOpt: ArgumentAcceptingOptionSpec[Integer]

  33. val messageSize: Int

  34. val messageSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Definition Classes
    PerfConfig

  35. val metricsDirectoryOpt: ArgumentAcceptingOptionSpec[String]

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

    Definition Classes
    AnyRef

  37. final def notify(): Unit

    Definition Classes
    AnyRef

  38. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  39. val numMessages: Long

  40. val numMessagesOpt: ArgumentAcceptingOptionSpec[Long]

    Definition Classes
    PerfConfig

  41. var numThreads: Int

  42. val numThreadsOpt: ArgumentAcceptingOptionSpec[Integer]

  43. val options: OptionSet

  44. val parser: OptionParser

    Definition Classes
    PerfConfig

  45. val producerNumRetries: Int

  46. val producerNumRetriesOpt: ArgumentAcceptingOptionSpec[Integer]

  47. val producerRequestRequiredAcks: Int

  48. val producerRequestRequiredAcksOpt: ArgumentAcceptingOptionSpec[Integer]

  49. val producerRequestTimeoutMs: Int

  50. val producerRequestTimeoutMsOpt: ArgumentAcceptingOptionSpec[Integer]

  51. val producerRetryBackOffMsOpt: ArgumentAcceptingOptionSpec[Integer]

  52. val producerRetryBackoffMs: Int

  53. val reportingInterval: Int

  54. val reportingIntervalOpt: ArgumentAcceptingOptionSpec[Integer]

    Definition Classes
    PerfConfig

  55. val seqIdMode: Boolean

  56. val showDetailedStatsOpt: OptionSpecBuilder

    Definition Classes
    PerfConfig

  57. val syncOpt: OptionSpecBuilder

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

    Definition Classes
    AnyRef

  59. def toString(): String

    Definition Classes
    AnyRef → Any

  60. val topics: Array[String]

  61. val topicsOpt: ArgumentAcceptingOptionSpec[String]

  62. val topicsStr: String

  63. val useNewProducer: Boolean

  64. val useNewProducerOpt: OptionSpecBuilder

  65. val varyMessageSizeOpt: OptionSpecBuilder

  66. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from PerfConfig

Inherited from AnyRef

Inherited from Any

Ungrouped