[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 Project:

[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 d

[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&focusedCommentId=16045857#comment-16045857 ] ASF GitHub Bot commented on KAFKA-5428: --- GitHub user hachikuji opened a pull request

[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 https://github.com/hachikuji/k

[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 Window

[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 been

[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] [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&focusedCommentId=16045936#comment-16045936 ] Evgeny Veretennikov commented on KAFKA-5245: There is Kstream.groupByKey() met

[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-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&focusedCommentId=16046071#comment-16046071 ] Jorge Quilcate commented on KAFKA-4743: --- I was about to ask you about the same :) I'

[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 remove-unused-admin

[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 KAFKA-5429

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 committers voted on this

[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 enab

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 in

Re: [ANNOUNCE] New committer: Damian Guy

Congratulations, Damian! On Sat, Jun 10, 2017 at 12:15 PM, Mickael Maison wrote: > Congrats Damian! > > On Sat, Jun 10, 2017 at 8:46 AM, Damian Guy wrote: > > Thanks everyone. Looking forward to making many more contributions > > On Sat, 10 Jun 2017 at 02:46, Joe Stein wrote: > > > >> Congrats