This is an automated email from the ASF dual-hosted git repository. xiangfu pushed a change to branch kafka_2.0 in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from d9e0316 Adding support for Kafka 2.0 add c01cc2e fixing the bytes type conversion and adding consumer test No new revisions were added by this update. Summary of changes: .../realtime/impl/kafka2/Kafka2MessageBatch.java | 7 ++- .../Kafka2PartitionLevelConnectionHandler.java | 3 +- ...Kafka2PartitionLevelPartitionLevelConsumer.java | 9 +-- .../kafka2/KafkaPartitionLevelConsumerTest.java | 66 +++++++++++++++++++++- 4 files changed, 74 insertions(+), 11 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org