Packages

package kafka

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class KafkaConfig (consumerProps: Properties, producerProps: Properties, streamProps: Properties) extends Product with Serializable
  2. abstract class KafkaDataMap [Key, Data <: Identifiable[Data]] extends DataMap[Key, Data]

    Created by edmundlam on 8/23/17.

  3. abstract class KafkaQueue [Data <: Identifiable[Data]] extends DataQueue[Data]

    Created by edmundlam on 8/19/17.

  4. class KafkaStream [Key, Data <: Identifiable[Data]] extends DataStream[(Key, Data)]

Value Members

  1. object KafkaConfig extends Serializable

    Created by edmundlam on 8/20/17.

Ungrouped