[jira] [Resolved] (KAFKA-13840) KafkaConsumer is unable to recover connection to group coordinator after commitOffsetsAsync exception

[ https://issues.apache.org/jira/browse/KAFKA-13840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-13840. --- Resolution: Fixed > KafkaConsumer is unable to recover connection to group coordinator after >

Re: KafkaConsumer refactor proposal

Hello Philip, Thanks for writing down the 1-pager. Just to clarify, the reason we wrote this as a 1-pager instead of a KIP is that so far all the implementations should be internal, and hence not impacting anything on the public APIs. If, e.g. we found along with the implementation that some

Re: KafkaConsumer refactor proposal

Hi Philip! Thanks for the write-up. On Tue, Sep 13, 2022, at 2:13 PM, Philip Nee wrote: > Hi all, > > Here is the proposal to refactor the Kafka Consumer > . > The 1-pager is on the wiki, so please

Re: [DISCUSS] KIP-864: Add End-To-End Latency Metrics to Connectors

Hi everyone, I've made a slight addition to the KIP based on Yash feedback: - A new metric is added at INFO level to record the max latency from the batch timestamp, by keeping the oldest record timestamp per batch. - A draft implementation is linked. Looking forward to your feedback. Also, a

[jira] [Created] (KAFKA-14235) Document MM2 auto topic creation behavior for MM2-internal topics

Maruthi created KAFKA-14235: --- Summary: Document MM2 auto topic creation behavior for MM2-internal topics Key: KAFKA-14235 URL: https://issues.apache.org/jira/browse/KAFKA-14235 Project: Kafka

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1229

See Changes: -- [...truncated 504948 lines...] [2022-09-15T16:56:55.687Z] KStreamAggregationIntegrationTest > shouldReduce(TestInfo) PASSED [2022-09-15T16:56:55.687Z]

[jira] [Resolved] (KAFKA-13632) MirrorMaker 2.0 NPE and Warning "Failure to commit records" for filtered records

[ https://issues.apache.org/jira/browse/KAFKA-13632?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13632. --- Resolution: Fixed > MirrorMaker 2.0 NPE and Warning "Failure to commit records" for

[jira] [Resolved] (KAFKA-13985) MirrorSourceTask commitRecord throws NPE if SMT is filtering out source record

[ https://issues.apache.org/jira/browse/KAFKA-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-13985. --- Resolution: Fixed > MirrorSourceTask commitRecord throws NPE if SMT is filtering out source

[jira] [Reopened] (KAFKA-7109) KafkaConsumer should close its incremental fetch sessions on close

[ https://issues.apache.org/jira/browse/KAFKA-7109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-7109: -- > KafkaConsumer should close its incremental fetch sessions on close >