[DISCUSS] KIP-92 - Add per partition lag metrics to KafkaConsumer

Hi, We created KIP-92 to propose adding per partition lag metrics to KafkaConsumer. The KIP wiki link is the following: https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+Add+per+partition+lag+metrics+to+KafkaConsumer Comments are welcome. Thanks, Jiangjie (Becket) Qin

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

See Changes: [me] KAFKA-3829: Ensure valid configuration prior to creating connector -- [...truncated 12129 lines...] org.apache.kafka.common.record.RecordTest > testChecksum[190] PASSED org.ap

[jira] [Commented] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names

[ https://issues.apache.org/jira/browse/KAFKA-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15660539#comment-15660539 ] ASF GitHub Bot commented on KAFKA-3829: --- Github user asfgit closed the pull request

[GitHub] kafka pull request #1911: KAFKA-3829: Ensure valid configuration prior to cr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1911 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Resolved] (KAFKA-3829) Warn that kafka-connect group.id must not conflict with connector names

[ https://issues.apache.org/jira/browse/KAFKA-3829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3829. -- Resolution: Fixed Fix Version/s: (was: 0.10.1.1) 0.

[jira] [Created] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

Jiangjie Qin created KAFKA-4401: --- Summary: Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class. Key: KAFKA-4401 URL: https://issues.apache.org/jira/browse/KAFKA-4401

Re: [VOTE] KIP-89: Allow sink connectors to decouple flush and offset commit

+1 (binding) On Fri, Nov 11, 2016 at 9:44 PM, Ewen Cheslack-Postava wrote: > +1 (binding) > > -Ewen > > On Wed, Nov 9, 2016 at 2:16 PM, Shikhar Bhushan > wrote: > > > Hi, > > > > I would like to initiate a vote on KIP-89 > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > > 89%3A+A

[jira] [Commented] (KAFKA-4398) offsetsForTimes returns false starting offset when timestamp of messages are not monotonically increasing

[ https://issues.apache.org/jira/browse/KAFKA-4398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15659333#comment-15659333 ] huxi commented on KAFKA-4398: - yes, what we really needs is to have the time index entry can b