kafka.tools.ConsoleProducer

ProducerConfig

class ProducerConfig extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ProducerConfig
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ProducerConfig(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. val batchSize: Integer

  8. val batchSizeOpt: ArgumentAcceptingOptionSpec[Integer]

  9. val brokerList: String

  10. val brokerListOpt: ArgumentAcceptingOptionSpec[String]

  11. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  12. val cmdLineProps: Properties

  13. val compressionCodec: String

  14. val compressionCodecOpt: ArgumentAcceptingOptionSpec[String]

  15. val compressionCodecOptionValue: String

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

    Definition Classes
    AnyRef
  17. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  18. val extraProducerProps: Properties

  19. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  20. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  21. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  22. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  23. val keyEncoderClass: String

  24. val keyEncoderOpt: ArgumentAcceptingOptionSpec[String]

  25. val maxBlockMs: Long

  26. val maxBlockMsOpt: ArgumentAcceptingOptionSpec[Long]

  27. val maxMemoryBytes: Long

  28. val maxMemoryBytesOpt: ArgumentAcceptingOptionSpec[Long]

  29. val maxPartitionMemoryBytes: Long

  30. val maxPartitionMemoryBytesOpt: ArgumentAcceptingOptionSpec[Long]

  31. val messageReaderOpt: ArgumentAcceptingOptionSpec[String]

  32. val messageSendMaxRetries: Integer

  33. val messageSendMaxRetriesOpt: ArgumentAcceptingOptionSpec[Integer]

  34. val metadataExpiryMs: Long

  35. val metadataExpiryMsOpt: ArgumentAcceptingOptionSpec[Long]

  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 options: OptionSet

  40. val parser: OptionParser

  41. val producerConfigOpt: ArgumentAcceptingOptionSpec[String]

  42. val producerPropertyOpt: ArgumentAcceptingOptionSpec[String]

  43. val propertyOpt: ArgumentAcceptingOptionSpec[String]

  44. val queueEnqueueTimeoutMs: Integer

  45. val queueEnqueueTimeoutMsOpt: ArgumentAcceptingOptionSpec[Integer]

  46. val queueSize: Integer

  47. val queueSizeOpt: ArgumentAcceptingOptionSpec[Integer]

  48. val readerClass: String

  49. val requestRequiredAcks: Integer

  50. val requestRequiredAcksOpt: ArgumentAcceptingOptionSpec[Integer]

  51. val requestTimeoutMs: Integer

  52. val requestTimeoutMsOpt: ArgumentAcceptingOptionSpec[Integer]

  53. val retryBackoffMs: Integer

  54. val retryBackoffMsOpt: ArgumentAcceptingOptionSpec[Integer]

  55. val sendTimeout: Integer

  56. val sendTimeoutOpt: ArgumentAcceptingOptionSpec[Integer]

  57. val socketBuffer: Integer

  58. val socketBufferSizeOpt: ArgumentAcceptingOptionSpec[Integer]

  59. val sync: Boolean

  60. val syncOpt: OptionSpecBuilder

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

    Definition Classes
    AnyRef
  62. def toString(): String

    Definition Classes
    AnyRef → Any
  63. val topic: String

  64. val topicOpt: ArgumentAcceptingOptionSpec[String]

  65. val useOldProducer: Boolean

  66. val useOldProducerOpt: OptionSpecBuilder

  67. val valueEncoderClass: String

  68. val valueEncoderOpt: ArgumentAcceptingOptionSpec[String]

  69. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  70. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  71. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped