Dose kafka connector rest aoi support multiple thread access?

2018-12-13 Thread tao tony
Dear teams, We use Kafka-1.1.0 connector to load data,And start a connector using rest api by application. Before we start a connector,we'll check it was not  existed and then create it. This was  encapsulated in a Quartz job.And each connector  had a job. We use spring resttemplate as below

Re: Kafka 2.1.0 JMX mbean broken ?

2018-12-13 Thread Ismael Juma
The metric was changed to include the API version. I believe this was in the upgrade notes for 2.0.0. Ismael On Thu, Dec 13, 2018, 3:35 PM Raghav Hi > > We are trying to move from Kafka 1.1.0 to Kafka 2.1.0. We used to monitor > our 3 node Kafka using JMX. Upon moving to 2.1.0, we have observed

Kafka 2.1.0 JMX mbean broken ?

2018-12-13 Thread Raghav
Hi We are trying to move from Kafka 1.1.0 to Kafka 2.1.0. We used to monitor our 3 node Kafka using JMX. Upon moving to 2.1.0, we have observed that the *below* mentioned metric can't be retrie and we get the below exception: *"kafka.network:type=RequestMetrics,name=RequestsPerSec,request=Produce

MAX_TASK_IDLE_MS_CONFIG not working?

2018-12-13 Thread Dmitry Minkovsky
I just discovered that 2.1.0 included MAX_TASK_IDLE_MS_CONFIG and dropped everything to play with it! Exciting! I built the following topology, attempting to synchronize two topic-partitions: https://gist.github.com/dminkovsky/45aa29aefefad564f9663cd36ad21ce1. However, I keep failing at https://g

Re: Kafka Trunk Build Failure with Gradle 5.0

2018-12-13 Thread Martin Gainty
there are at least 12 things that can go wrong with any gradle build if you can provider a link to the source-tree you are building we can be narrow down the reasons you are experiencing NoSuchMethodError for version of Kafka T & R From: Boyang Chen Sent: W

RE: Kafka data log retention policy for topics

2018-12-13 Thread 赖剑清
Hi, Could you have a try using the kafka-config.sh in kafka’s bin folder? From: Parth Gandhi [mailto:parth.gan...@excellenceinfonet.com] Sent: Wednesday, December 12, 2018 10:20 PM To: users@kafka.apache.org Subject: Kafka data log retention policy for topics All, We can set the retention polic