ClientUtils

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 channelToAnyBroker(zkClient: ZkClient, socketTimeoutMs: Int = 3000): BlockingChannel

   Creates a blocking channel to a random broker

8. def channelToOffsetManager(group: String, zkClient: ZkClient, socketTimeoutMs: Int = 3000, retryBackOffMs: Int = 1000): BlockingChannel

   Creates a blocking channel to the offset manager of the given group

9. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

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 fetchTopicMetadata(topics: Set[String], brokers: Seq[Broker], clientId: String, timeoutMs: Int, correlationId: Int = 0): TopicMetadataResponse

    Used by a non-producer client to send a metadata request

    Used by a non-producer client to send a metadata request

    topics

    The topics for which the metadata needs to be fetched

    brokers

    The brokers in the cluster as configured on the client

    clientId

    The client's identifier

    returns

    topic metadata response

22. def fetchTopicMetadata(topics: Set[String], brokers: Seq[Broker], producerConfig: ProducerConfig, correlationId: Int): TopicMetadataResponse

    Used by the producer to send a metadata request since it has access to the ProducerConfig

    Used by the producer to send a metadata request since it has access to the ProducerConfig

    topics

    The topics for which the metadata needs to be fetched

    brokers

    The brokers in the cluster as configured on the producer through metadata.broker.list

    producerConfig

    The producer's config

    returns

    topic metadata response

23. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    Definition Classes

    AnyRef → Any

25. def hashCode(): Int

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

29. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

30. var logIdent: String

    Attributes

    protected

    Definition Classes

    Logging

31. lazy val logger: Logger

    Definition Classes

    Logging

32. val loggerName: String

    Definition Classes

    Logging

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

    Definition Classes

    AnyRef

34. final def notify(): Unit

    Definition Classes

    AnyRef

35. final def notifyAll(): Unit

    Definition Classes

    AnyRef

36. def parseBrokerList(brokerListStr: String): Seq[Broker]

    Parse a list of broker urls in the form host1:port1, host2:port2, .

    Parse a list of broker urls in the form host1:port1, host2:port2, ...

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    AnyRef

44. def toString(): String

    Definition Classes

    AnyRef → Any

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

48. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging

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

    Definition Classes

    Logging