ConsumeData
LjlIterable;
ConsumeDataIterator
AbstractIterator
CloseableIterator
ConsumeTopicRunnable
Callable
DatumGenerator
DefaultCSVDatumGenerator
KafkaUtils
LargeMessageIT
OryxTest
LocalKafkaBroker
LjiCloseable;
LocalZKServer
ProduceConsumeIT
ProduceData
A iterator that consumes data from a Kafka topic.
An iterator over records in a Kafka topic. @param < K > key type @param < V > value type
Implementations are Iterator s that are also Closeable . @param < T > iterator element type
Interface which generates one datum. @param < K > key type @param < M > message type
Interface which generates one random datum.
Kafka-related utility methods.
Runs a local instance of the Kafka broker. Useful for testing.
This class contains code copied from Zookeeper's QuorumPeerMain and ZooKeeperServerMain. It runs ...
Tests ProduceData and ConsumeData together.
A process that will continually send data to a Kafka topic. This is useful for testing purposes. ...
Oryx Architecture Diagrams | documentation produced by SourceSpy

Package com.cloudera.oryx.kafka.util

https://github.com/OryxProject/oryx/tree/master/framework/kafka-util/src/test/java/com/cloudera/oryx/kafka/util
Kafka-related utility code and command-line applications.
Classes
com.cloudera.oryx.kafka.util
org.apache.kafka.clients.consumer
com.cloudera.oryx.api
org.slf4j
kafka.server
org.apache.zookeeper.server
org.apache.zookeeper.server.persistence
com.cloudera.oryx.lambda
com.cloudera.oryx.app.serving.als.model
com.cloudera.oryx.common.settings
org.apache.commons.math3.random
kafka.utils
com.cloudera.oryx.common.collection
com.cloudera.oryx.common.io
com.typesafe.config
com.cloudera.oryx.common.lang
org.apache.zookeeper.server.quorum
com.cloudera.oryx.common.random
com.cloudera.oryx.lambda.batch
com.cloudera.oryx.lambda.serving
com.cloudera.oryx.lambda.speed
Package Dependencies
datumGenerator