utils

Value Members

1. object Logkafka extends Logging

   

   Borrowed from kafka 0.8.1.1 https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/common/Logkafka.scala

2. object LogkafkaErrors

   

3. object LogkafkaNewConfigs

   

4. object LogkafkaZkUtils

   

5. object Topic

   

   Borrowed from kafka 0.8.1.1 https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/common/Topic.scala

6. object TopicConfigs

   

7. object TopicErrors

   

8. object ZkUtils

   

   Borrowed from kafka 0.8.1.1.

   Borrowed from kafka 0.8.1.1. Adapted to use curator framework. https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/utils/ZkUtils.scala

9. def checkCondition(cond: Boolean, error: UtilError): Unit

   

   Annotations

   @throws( ... )

10. implicit def deserializeString(data: Array[Byte]): String

    

11. implicit val formats: DefaultFormats.type

    

12. def fromJson[T](s: String): T

    

13. package logkafka81

    

14. package logkafka82

    

15. def parseJson(s: String): JValue

    

16. object repeatWithIndex

    

17. implicit def serializeString(data: String): Array[Byte]

    

18. def throwError[T](error: UtilError): T

    

    Annotations

    @throws( ... )

19. def toJson(s: String): String

    

20. def toJson(map: Map[String, Any]): String

    

21. package zero81

    

22. package zero82

    

23. package zero90