Re: [DISCUSS]: KIP-161: streams record processing exception handlers

Eno, Thanks for bringing this proposal up and sorry for getting late on this. Here are my two cents: 1. First some meta comments regarding "fail fast" v.s. "making progress". I agree that in general we should better "enforce user to do the right thing" in system design, but we also need to keep

[GitHub] kafka pull request #3265: KAFKA-5405: Request log should log throttle time

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3265 --- 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

Re: Reg: [VOTE] KIP 157 - Add consumer config options to streams reset tool

Thanks everyone for voting. KIP-157 has passed with +3 binding (Ewen, Jason and Guozhang Wang) and +3 non-binding (Matthias J. Sax and Bill Bejeck) Thanks, Bharat Viswanadham On Sat, Jun 10, 2017 at 4:49 PM, Guozhang Wang wrote: > Bharat, > > I think we already have 3

[GitHub] kafka pull request #3300: KAFKA-5429: Ignore produce response if batch was p...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3300 KAFKA-5429: Ignore produce response if batch was previously aborted You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka pull request #3299: MINOR: Remove unused `AdminUtils.fetchTopicMetadat...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/3299 MINOR: Remove unused `AdminUtils.fetchTopicMetadataFromZk` methods You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[jira] [Commented] (KAFKA-4743) Add a tool to Reset Consumer Group Offsets

[ https://issues.apache.org/jira/browse/KAFKA-4743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16046071#comment-16046071 ] Jorge Quilcate commented on KAFKA-4743: --- I was about to ask you about the same :) I'd be keen to

[jira] [Created] (KAFKA-5430) new consumers getting data for revoked partitions

Lior Chaga created KAFKA-5430: - Summary: new consumers getting data for revoked partitions Key: KAFKA-5430 URL: https://issues.apache.org/jira/browse/KAFKA-5430 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-5245) KStream builder should capture serdes

[ https://issues.apache.org/jira/browse/KAFKA-5245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16045936#comment-16045936 ] Evgeny Veretennikov commented on KAFKA-5245: There is Kstream.groupByKey() method, which

[jira] [Created] (KAFKA-5429) Producer IllegalStateException: Batch has already been completed

Jason Gustafson created KAFKA-5429: -- Summary: Producer IllegalStateException: Batch has already been completed Key: KAFKA-5429 URL: https://issues.apache.org/jira/browse/KAFKA-5429 Project: Kafka

[jira] [Updated] (KAFKA-5377) Kafka server process crashing due to access violation (caused by log cleaner)

[ https://issues.apache.org/jira/browse/KAFKA-5377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Markus B updated KAFKA-5377: Description: We are running Kafka in a 2 x broker cluster configuration on Windows, and overall it has

[jira] [Updated] (KAFKA-5377) Kafka server process crashing due to access violation (caused by log cleaner)

[ https://issues.apache.org/jira/browse/KAFKA-5377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Markus B updated KAFKA-5377: Attachment: LogSegment.scala AbstractIndex.scala Modified two files to address bug on

[GitHub] kafka pull request #3298: KAFKA-5428: Transactional producer should only abo...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/3298 KAFKA-5428: Transactional producer should only abort batches in fatal error state You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

[ https://issues.apache.org/jira/browse/KAFKA-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16045857#comment-16045857 ] ASF GitHub Bot commented on KAFKA-5428: --- GitHub user hachikuji opened a pull request:

[jira] [Updated] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

[ https://issues.apache.org/jira/browse/KAFKA-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5428: --- Description: We currently abort batches blindly if we are in any error state. We should only

[jira] [Created] (KAFKA-5428) Transactional producer aborts batches incorrectly in abortable error state

Jason Gustafson created KAFKA-5428: -- Summary: Transactional producer aborts batches incorrectly in abortable error state Key: KAFKA-5428 URL: https://issues.apache.org/jira/browse/KAFKA-5428