new pom.xml for samza-parent-project

Martin Gainty has shared a OneDrive file with you. To view it, click the link below. [https://r1.res.office365.com/owa/prem/images/dc-generic_20.png] pom

new pom.xml for samza-grid

Martin Gainty has shared a OneDrive file with you. To view it, click the link below. [https://r1.res.office365.com/owa/prem/images/dc-generic_20.png]

Flink on Yarn -Connection unexpectedly close dby remote task manager..

Hey all, My jobs that I am trying to write in Flink 1.5 are failing after a few minutes. I recon its because the idle task managers are shutting down, but it seems to kill the client and the running job, which was still going on one of the other task managers. either way I get:

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

Please find the kafka and samza dependencies in the below link https://gist.github.com/debraj-manna/d51af1896d74b68da55f0ef252886692 On Fri, Jun 15, 2018 at 9:14 PM, Martin Gainty wrote: > unable to determine execution scenario without seeing pom.xml > > > please supply pom.xml > > > Martin >

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

unable to determine execution scenario without seeing pom.xml please supply pom.xml Martin __ From: Debraj Manna Sent: Friday, June 15, 2018 11:11 AM To: users@kafka.apache.org Subject: Re: NoClassDefFoundError

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

Martin Everything is working fine with samza 0.12. I am now trying to upgrade to latest samza 0.14.1 which is causing this issue. I am posting the relevant part from the output of mvn dependency:tree -Dincludes=org.apache.kafka*,org.apache.samza . [INFO]

Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

a strong possibility is that kafka-core is missing as a dependency for samza please supply samza pom.xml Martin __ From: Debraj Manna Sent: Friday, June 15, 2018 10:52 AM To: users@kafka.apache.org Subject:

NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0

Hi I have posted the same in d...@samza.apache.org , posting it here also if anyone is aware. *I am trying to use samza 0.14.2 with Kafka Client 0.10.0 . I am getting the below exception. Is this related to https://issues.apache.org/jira/browse/SAMZA-1509

KafkaMetricsReporter implementing BrokerMetricsReporterMBean not calling stopReporter()

Hi, We have implemented a reporter implementing BrokerMetricsReporterMBean. We run in embedded mode. Reporters are started using kafkaMetricsReporters = KafkaMetricsReporter$.MODULE$.startReporters(new VerifiableProperties(kafkaProperties)); kafkaServer = new KafkaServer(kafkaConfig,

SQL Server CDC

Hello, Good day!!! I have requirement to capture change of SQL Server; but I don't want to use SQL Server Replication. I can't use SQL Server CDC because limitation of SQL Server version. I know I can achieve using Kafka-Connect API but don't know how to do it. Would you please do the needful