This is an automated email from the ASF dual-hosted git repository.
saniljain15 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from 93c41df SAMZA-2627: Make StreamAppender extensible for sending
messages to SystemProducer (#1470)
add 89b71ed SAMZA-2617: Upgrade Kafka Client to 2.3.1 (#1462)
No new revisions were added by this update.
Summary of changes:
gradle/dependency-versions.gradle | 2 +-
.../samza/system/kafka/KafkaConsumerProxy.java | 14 ++++-----
.../samza/system/kafka/KafkaSystemConsumer.java | 9 ++----
.../system/kafka/KafkaSystemConsumerMetrics.scala | 34 +++++++++++-----------
.../samza/system/kafka/MockKafkaProducer.java | 6 ++++
.../kafka/TestKafkaSystemConsumerMetrics.java | 10 +++----
.../samza/sql/client/impl/SamzaExecutor.java | 9 ++----
.../samza/test/processor/TestStreamProcessor.java | 19 ++++++------
.../harness/AbstractKafkaServerTestHarness.scala | 2 +-
.../harness/AbstractZookeeperTestHarness.scala | 9 ++----
10 files changed, 53 insertions(+), 61 deletions(-)
