Producer

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. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

8. def close(): Unit

   Close API to close the producer pool connections to all Kafka brokers.

   Close API to close the producer pool connections to all Kafka brokers. Also closes the zookeeper client connection if one exists

9. val config: ProducerConfig

10. def debug(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes

    Logging

11. def debug(e: ⇒ Throwable): Any

    Definition Classes

    Logging

12. def debug(msg: ⇒ String): Unit

    Definition Classes

    Logging

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

    Definition Classes

    AnyRef

14. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

15. def error(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes

    Logging

16. def error(e: ⇒ Throwable): Any

    Definition Classes

    Logging

17. def error(msg: ⇒ String): Unit

    Definition Classes

    Logging

18. def fatal(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes

    Logging

19. def fatal(e: ⇒ Throwable): Any

    Definition Classes

    Logging

20. def fatal(msg: ⇒ String): Unit

    Definition Classes

    Logging

21. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

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

    Definition Classes

    AnyRef → Any

23. def hashCode(): Int

    Definition Classes

    AnyRef → Any

24. def info(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes

    Logging

25. def info(e: ⇒ Throwable): Any

    Definition Classes

    Logging

26. def info(msg: ⇒ String): Unit

    Definition Classes

    Logging

27. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

28. var logIdent: String

    Attributes

    protected

    Definition Classes

    Logging

29. lazy val logger: Logger

    Definition Classes

    Logging

30. val loggerName: String

    Definition Classes

    Logging

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

    Definition Classes

    AnyRef

32. final def notify(): Unit

    Definition Classes

    AnyRef

33. final def notifyAll(): Unit

    Definition Classes

    AnyRef

34. def send(messages: KeyedMessage[K, V]*): Unit

    Sends the data, partitioned by key to the topic using either the synchronous or the asynchronous producer

    Sends the data, partitioned by key to the topic using either the synchronous or the asynchronous producer

    messages

    the producer data object that encapsulates the topic, key and message data

35. def swallow(action: ⇒ Unit): Unit

    Definition Classes

    Logging

36. def swallowDebug(action: ⇒ Unit): Unit

    Definition Classes

    Logging

37. def swallowError(action: ⇒ Unit): Unit

    Definition Classes

    Logging

38. def swallowInfo(action: ⇒ Unit): Unit

    Definition Classes

    Logging

39. def swallowTrace(action: ⇒ Unit): Unit

    Definition Classes

    Logging

40. def swallowWarn(action: ⇒ Unit): Unit

    Definition Classes

    Logging

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

    Definition Classes

    AnyRef

42. def toString(): String

    Definition Classes

    AnyRef → Any

43. def trace(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes

    Logging

44. def trace(e: ⇒ Throwable): Any

    Definition Classes

    Logging

45. def trace(msg: ⇒ String): Unit

    Definition Classes

    Logging

46. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

49. def warn(msg: ⇒ String, e: ⇒ Throwable): Unit

    Definition Classes

    Logging

50. def warn(e: ⇒ Throwable): Any

    Definition Classes

    Logging

51. def warn(msg: ⇒ String): Unit

    Definition Classes

    Logging