----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/17405/ -----------------------------------------------------------
Review request for Twill. Repository: twill Description ------- This is the change to upgrade to Kafka-0.8. It also have the Kafka client code refactored to give easier API to use. Diffs ----- pom.xml 0c6e9dd twill-core/pom.xml faff711 twill-core/src/main/java/org/apache/twill/internal/AbstractTwillController.java 97e0a8f twill-core/src/main/java/org/apache/twill/internal/Constants.java 0387d3e twill-core/src/main/java/org/apache/twill/internal/kafka/EmbeddedKafkaServer.java 14dfc70 twill-core/src/main/java/org/apache/twill/internal/kafka/client/AbstractCompressedMessageSetEncoder.java a9c3381 twill-core/src/main/java/org/apache/twill/internal/kafka/client/AbstractMessageSetEncoder.java 9955d6a twill-core/src/main/java/org/apache/twill/internal/kafka/client/BasicFetchedMessage.java 286bf82 twill-core/src/main/java/org/apache/twill/internal/kafka/client/Bufferer.java c1fb4f2 twill-core/src/main/java/org/apache/twill/internal/kafka/client/ByteBufferEncoder.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/Compression.java 3355b9f twill-core/src/main/java/org/apache/twill/internal/kafka/client/ConnectionPool.java c2865ba twill-core/src/main/java/org/apache/twill/internal/kafka/client/GZipMessageSetEncoder.java daa0c2c twill-core/src/main/java/org/apache/twill/internal/kafka/client/IdentityMessageSetEncoder.java 51dc746 twill-core/src/main/java/org/apache/twill/internal/kafka/client/IntegerEncoder.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/IntegerPartitioner.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaBrokerCache.java f2bb815 twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaRequest.java 7b43f8a twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaRequestEncoder.java ef78c76 twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaRequestSender.java fbc552c twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaResponse.java 68c1bd8 twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaResponseDispatcher.java 47f70ce twill-core/src/main/java/org/apache/twill/internal/kafka/client/KafkaResponseHandler.java 5251e65 twill-core/src/main/java/org/apache/twill/internal/kafka/client/MessageFetcher.java 0814917 twill-core/src/main/java/org/apache/twill/internal/kafka/client/MessageSetEncoder.java 49008cc twill-core/src/main/java/org/apache/twill/internal/kafka/client/ResponseHandler.java f681b85 twill-core/src/main/java/org/apache/twill/internal/kafka/client/SimpleKafkaClient.java 8ff4856 twill-core/src/main/java/org/apache/twill/internal/kafka/client/SimpleKafkaConsumer.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/SimpleKafkaPublisher.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/SnappyMessageSetEncoder.java bf18c08 twill-core/src/main/java/org/apache/twill/internal/kafka/client/TopicBroker.java fd4bf03 twill-core/src/main/java/org/apache/twill/internal/kafka/client/ZKBrokerService.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/ZKKafkaClientService.java PRE-CREATION twill-core/src/main/java/org/apache/twill/internal/kafka/client/package-info.java f3f615c twill-core/src/main/java/org/apache/twill/internal/logging/KafkaAppender.java 12818ef twill-core/src/main/java/org/apache/twill/internal/logging/KafkaTwillRunnable.java c1695de twill-core/src/main/java/org/apache/twill/kafka/client/BrokerInfo.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/BrokerService.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/Compression.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/FetchException.java acccf04 twill-core/src/main/java/org/apache/twill/kafka/client/FetchedMessage.java 65e140f twill-core/src/main/java/org/apache/twill/kafka/client/KafkaClient.java 496195b twill-core/src/main/java/org/apache/twill/kafka/client/KafkaClientService.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/KafkaConsumer.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/KafkaPublisher.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/PreparePublish.java 5db4abb twill-core/src/main/java/org/apache/twill/kafka/client/TopicPartition.java PRE-CREATION twill-core/src/main/java/org/apache/twill/kafka/client/package-info.java ea3bf20 twill-core/src/main/resources/kafka-0.7.2.tgz 24178d9 twill-core/src/test/java/org/apache/twill/kafka/client/KafkaTest.java 40fc3ed twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterService.java 51c8503 twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java 17425d4 Diff: https://reviews.apache.org/r/17405/diff/ Testing ------- Thanks, Terence Yim
