ProducerPerfConfig

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( ... )