[GitHub] [samza] prateekm commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass

prateekm commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass URL: https://github.com/apache/samza/pull/978#discussion_r269637384 ## File path: samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSna

[GitHub] [samza] shanthoosh commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass

shanthoosh commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass URL: https://github.com/apache/samza/pull/978#discussion_r269649574 ## File path: samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsS

[GitHub] [samza] srinipunuru opened a new pull request #979: SAMZA-2110 : Support for deleting records from a table

srinipunuru opened a new pull request #979: SAMZA-2110 : Support for deleting records from a table URL: https://github.com/apache/samza/pull/979 1. Commit adds support for deleting records from table by adding a special __op__ field. SQL users can use this field to say whether the row need

[GitHub] [samza] rmatharu commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass

rmatharu commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass URL: https://github.com/apache/samza/pull/978#discussion_r269684095 ## File path: samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSna

[GitHub] [samza] rmatharu commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass

rmatharu commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass URL: https://github.com/apache/samza/pull/978#discussion_r269684095 ## File path: samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsSna

[GitHub] [samza] shanthoosh commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass

shanthoosh commented on a change in pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass URL: https://github.com/apache/samza/pull/978#discussion_r269704869 ## File path: samza-core/src/main/scala/org/apache/samza/metrics/reporter/MetricsS

[GitHub] [samza] atoomula merged pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass

atoomula merged pull request #978: SAMZA-1733 : Making MetricsSnapshotReporter look for appclass then taskclass URL: https://github.com/apache/samza/pull/978 This is an automated message from the Apache Git Service. To respo

[GitHub] [samza] mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0

mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951#discussion_r269747886 ## File path: samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java ## @@ -594,7 +593,13 @@

[GitHub] [samza] mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0

mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951#discussion_r269747800 ## File path: samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java ## @@ -594,7 +593,13 @@

[GitHub] [samza] mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0

mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951#discussion_r269749949 ## File path: samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala ## @@ -169,59 +16

[GitHub] [samza] mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0

mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951#discussion_r269750016 ## File path: gradle/dependency-versions.gradle ## @@ -34,7 +34,7 @@ jodaTimeVersion = "2.2" joptSimpleVersion

[GitHub] [samza] mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0

mynameborat commented on a change in pull request #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951#discussion_r269750805 ## File path: samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java ## @@ -0,0 +1,192

Re: SSL with Samza 0.14.1?

+ Xinyu. I think he's still working on merging the remaining 1.0 changes to the Beam runner. On Tue, Mar 26, 2019 at 3:35 PM LeVeck, Matt wrote: > Thanks Prateek. I think I’ve switched all of the relevant libraries to > Beam Runner 2.12-SNAPSHOTl, and Samza 1.1.0. But for some reason it’s > st

[GitHub] [samza] shanthoosh merged pull request #951: SAMZA-2127: Upgrade to Kafka 2.0

shanthoosh merged pull request #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [samza] shanthoosh commented on issue #951: SAMZA-2127: Upgrade to Kafka 2.0

shanthoosh commented on issue #951: SAMZA-2127: Upgrade to Kafka 2.0 URL: https://github.com/apache/samza/pull/951#issuecomment-477460707 @mynameborat Thanks for the changes. Merged it to trunk. This is an automated messag