Class

kafka.tools.ConsoleProducer

ProducerConfig

Related Doc: package ConsoleProducer

Permalink

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
Visibility
  1. Public
  2. All

Instance Constructors

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

    Permalink

  6. val batchSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  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 cmdLineProps: Properties

    Permalink

  11. val compressionCodec: String

    Permalink

  12. val compressionCodecOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  13. val compressionCodecOptionValue: String

    Permalink

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

    Permalink
    Definition Classes
    AnyRef

  15. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  16. val extraProducerProps: Properties

    Permalink

  17. def finalize(): Unit

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

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

    Permalink
    Definition Classes
    AnyRef → Any

  19. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  20. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  21. val keyEncoderClass: String

    Permalink

  22. val keyEncoderOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  23. val maxBlockMs: Long

    Permalink

  24. val maxBlockMsOpt: ArgumentAcceptingOptionSpec[Long]

    Permalink

  25. val maxMemoryBytes: Long

    Permalink

  26. val maxMemoryBytesOpt: ArgumentAcceptingOptionSpec[Long]

    Permalink

  27. val maxPartitionMemoryBytes: Long

    Permalink

  28. val maxPartitionMemoryBytesOpt: ArgumentAcceptingOptionSpec[Long]

    Permalink

  29. val messageReaderOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  30. val messageSendMaxRetries: Integer

    Permalink

  31. val messageSendMaxRetriesOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  32. val metadataExpiryMs: Long

    Permalink

  33. val metadataExpiryMsOpt: ArgumentAcceptingOptionSpec[Long]

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

    Permalink

  38. val parser: OptionParser

    Permalink

  39. val producerConfigOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  40. val producerPropertyOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  41. val propertyOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  42. val queueEnqueueTimeoutMs: Integer

    Permalink

  43. val queueEnqueueTimeoutMsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  44. val queueSize: Integer

    Permalink

  45. val queueSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  46. val readerClass: String

    Permalink

  47. val requestRequiredAcks: Integer

    Permalink

  48. val requestRequiredAcksOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  49. val requestTimeoutMs: Integer

    Permalink

  50. val requestTimeoutMsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  51. val retryBackoffMs: Integer

    Permalink

  52. val retryBackoffMsOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  53. val sendTimeout: Integer

    Permalink

  54. val sendTimeoutOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  55. val socketBuffer: Integer

    Permalink

  56. val socketBufferSizeOpt: ArgumentAcceptingOptionSpec[Integer]

    Permalink

  57. val sync: Boolean

    Permalink

  58. val syncOpt: OptionSpecBuilder

    Permalink

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

    Permalink
    Definition Classes
    AnyRef

  60. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  61. val topic: String

    Permalink

  62. val topicOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  63. val useOldProducer: Boolean

    Permalink

  64. val useOldProducerOpt: OptionSpecBuilder

    Permalink

  65. val valueEncoderClass: String

    Permalink

  66. val valueEncoderOpt: ArgumentAcceptingOptionSpec[String]

    Permalink

  67. final def wait(): Unit

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

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

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

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

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

Inherited from AnyRef

Inherited from Any

Ungrouped