[jira] [Created] (KAFKA-7613) Enable javac rawtypes, serial and try xlint warnings

Ismael Juma created KAFKA-7613: -- Summary: Enable javac rawtypes, serial and try xlint warnings Key: KAFKA-7613 URL: https://issues.apache.org/jira/browse/KAFKA-7613 Project: Kafka Issue Type: Su

[jira] [Created] (KAFKA-7614) Fix scalac warnings and enable warnings as errors

Ismael Juma created KAFKA-7614: -- Summary: Fix scalac warnings and enable warnings as errors Key: KAFKA-7614 URL: https://issues.apache.org/jira/browse/KAFKA-7614 Project: Kafka Issue Type: Sub-t

[jira] [Created] (KAFKA-7612) Fix javac warnings and enable warnings as errors

Ismael Juma created KAFKA-7612: -- Summary: Fix javac warnings and enable warnings as errors Key: KAFKA-7612 URL: https://issues.apache.org/jira/browse/KAFKA-7612 Project: Kafka Issue Type: Sub-ta

[jira] [Created] (KAFKA-7611) Eliminate compiler warnings in Kafka

Ismael Juma created KAFKA-7611: -- Summary: Eliminate compiler warnings in Kafka Key: KAFKA-7611 URL: https://issues.apache.org/jira/browse/KAFKA-7611 Project: Kafka Issue Type: Improvement

Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id

Hi Boyang, Thanks for the reply. Please find the replies inline below : For having a consumer config at runtime, I think it's not necessary to address in this KIP because most companies run sidecar jobs through daemon software like puppet. It should be easy to change the config through script or

[jira] [Resolved] (KAFKA-7604) Flaky Test `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailableWithPatternSubscribe`

[ https://issues.apache.org/jira/browse/KAFKA-7604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian resolved KAFKA-7604. Resolution: Fixed > Flaky Test > `ConsumerCoordinatorTest.testRebalanceAfterTopicUnavailab

Build failed in Jenkins: kafka-trunk-jdk8 #3191

See Changes: [github] MINOR: Update zstd, easymock, powermock, zkclient and build plugins -- [...truncated 2.49 MB...] org.apache.kafka.connect.transforms.CastTest > testC

Re: [DISCUSS] KIP-258: Allow to Store Record Timestamps in RocksDB

Hello Matthias I am curious as to the status of this KIP. TTL and expiry of records will be extremely useful for several of our business use-cases, as well as another KIP I had been working on. Thanks On Mon, Aug 13, 2018 at 10:29 AM Eno Thereska wrote: > Hi Matthias, > > Good stuff. Could y

Introducing Kafka Hawk: Monitoring Consumer Group Commit Frequency

Hey everyone, I wanted to share a small tool I developed last weekend named Kafka Hawk. Kafka Hawk monitors the __consumer_offsets topic in Kafka and reports on the number of commits it sees from each consumer group and topic. It can also optionally report information on the deltas between offset

Re: Query Kafka Connect

No this is he name I have provided for transform name in Config file. Regards Sanjeev Jain > On Nov 10, 2018, at 4:18 AM, Ryanne Dolan wrote: > > Stupid question: do you have transforms=DateConvert as well? > >> On Fri, Nov 9, 2018, 9:00 PM sanjeev0915 wrote: >> Hi >> >> Please help for the