sqoop-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gwen Shapira" <gshap...@cloudera.com>
Subject Review Request 28802: SQOOP-1852: Sqoop2: Kafka connector supporting TO direction
Date Mon, 08 Dec 2014 14:35:49 GMT

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/28802/
-----------------------------------------------------------

Review request for Sqoop.


Repository: sqoop-sqoop2


Description
-------

SQOOP-1852: Sqoop2: Kafka connector supporting TO direction


Diffs
-----

  connector/connector-kafka/pom.xml PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaConnector.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaConnectorErrors.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaConstants.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaLoader.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaToDestroyer.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/KafkaToInitializer.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/configuration/JobConfig.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/configuration/JobConfiguration.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/configuration/LinkConfig.java
PRE-CREATION 
  connector/connector-kafka/src/main/java/org/apache/sqoop/connector/kafka/configuration/LinkConfiguration.java
PRE-CREATION 
  connector/connector-kafka/src/main/resources/kafka-connector-config.properties PRE-CREATION

  connector/connector-kafka/src/main/resources/sqoopconnector.properties PRE-CREATION 
  connector/connector-kafka/src/test/java/org/apache/sqoop/connector/kafka/TestKafkaLoader.java
PRE-CREATION 
  connector/connector-kafka/src/test/java/org/apache/sqoop/connector/kafka/utils/KafkaConsumer.java
PRE-CREATION 
  connector/connector-kafka/src/test/java/org/apache/sqoop/connector/kafka/utils/KafkaLocal.java
PRE-CREATION 
  connector/connector-kafka/src/test/java/org/apache/sqoop/connector/kafka/utils/TestUtil.java
PRE-CREATION 
  connector/connector-kafka/src/test/java/org/apache/sqoop/connector/kafka/utils/ZooKeeperLocal.java
PRE-CREATION 
  connector/connector-kafka/src/test/resources/kafka-server.properties PRE-CREATION 
  connector/connector-kafka/src/test/resources/log4j.properties PRE-CREATION 
  connector/pom.xml da4ed3e 
  pom.xml e182176 

Diff: https://reviews.apache.org/r/28802/diff/


Testing
-------

Unit tests only for now.


Thanks,

Gwen Shapira


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message