[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984341#comment-15984341 ] Naman Gupta commented on KAFKA-4477: Hi! All, I am getting same issue kafka_2.12-0.10.

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Made a slight change to the wiki since I had forgotten to state the fact that some APIs don’t take a store name, but a StateStoreSupplier (that contains the name). That’s already the case in the code but thought of making that explicit. FYI, no action needed. Thanks Eno > On Apr 21, 2017, at 7:

[GitHub] kafka pull request #2531: KAFKA-1610: Review usages of Map#mapValues.

Github user jozi-k closed the pull request at: https://github.com/apache/kafka/pull/2531 --- 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] [Commented] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

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

[jira] [Updated] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Buffington updated KAFKA-5122: -- Summary: Kafka Streams unexpected off-heap memory growth (was: Kafka Streams off-heap memory le

[jira] [Updated] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jon Buffington updated KAFKA-5122: -- Priority: Minor (was: Major) > Kafka Streams unexpected off-heap memory growth > --

Re: [DISCUSS] KIP-137: Enhance TopicCommand --describe to show topics marked for deletion

Thanks for the feedback. I had the same thinking as James. Also we plan to only add the MarkedForDeletion field for topics pending deletion as the output of --describe is already pretty dense and most topics are never pending deletion. The only reason I came up to insert it in the middle is if Co

[jira] [Commented] (KAFKA-5122) Kafka Streams unexpected off-heap memory growth

[ https://issues.apache.org/jira/browse/KAFKA-5122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984467#comment-15984467 ] Jon Buffington commented on KAFKA-5122: --- There was not a leak; I was miscalculating

Re: [VOTE] 0.10.2.1 RC3

+1 Started using kafka client 0.10.2.1 for our streams applications, seen a much greater improvement on retries when failures occur. We've been running without manual intervention for > 24 hours which is something we haven't seen in awhile. Found it odd that the RC tag wasn't within the version o

Re: [DISCUSS] KIP-137: Enhance TopicCommand --describe to show topics marked for deletion

Right, the reason for inserting it before the configs is that MarkedForDeletion is a fixed length field while configs is a variable length field. The fact that MarkedForDeletion is optional and typically not set means that it's also justifiable to place it after the configs. So, I'm OK either way.

[GitHub] kafka pull request #2918: 0.10.2

GitHub user jpi-atos opened a pull request: https://github.com/apache/kafka/pull/2918 0.10.2 essai You can merge this pull request into a Git repository by running: $ git pull https://github.com/apache/kafka 0.10.2 Alternatively you can review and apply these changes as the pa

[jira] [Work started] (KAFKA-5127) Replace pattern matching with foreach where the case None is unused

[ https://issues.apache.org/jira/browse/KAFKA-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5127 started by Balint Molnar. > Replace pattern matching with foreach where the case None is unused >

[jira] [Created] (KAFKA-5127) Replace pattern matching with foreach where the case None is unused

Balint Molnar created KAFKA-5127: Summary: Replace pattern matching with foreach where the case None is unused Key: KAFKA-5127 URL: https://issues.apache.org/jira/browse/KAFKA-5127 Project: Kafka

[GitHub] kafka pull request #2919: KAFKA-5127 Replace pattern matching with foreach w...

GitHub user baluchicken opened a pull request: https://github.com/apache/kafka/pull/2919 KAFKA-5127 Replace pattern matching with foreach where the case None … @ijuma plz review. This one is not complete because KafkaController, AdminUtils and ReplicaStateMachine has some of these

[jira] [Commented] (KAFKA-5127) Replace pattern matching with foreach where the case None is unused

[ https://issues.apache.org/jira/browse/KAFKA-5127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984837#comment-15984837 ] ASF GitHub Bot commented on KAFKA-5127: --- GitHub user baluchicken opened a pull reque

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984850#comment-15984850 ] Domenico Di Giulio commented on KAFKA-5016: --- [~vahid], yes this seems to be conf

[GitHub] kafka pull request #2920: Minor: IntegrationTestUtils were not handling prod...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2920 Minor: IntegrationTestUtils were not handling producer and consumer in a resource-safe manner Producer and Consumer `close` calls were not handled via `try-with-resources` You can merge

[GitHub] kafka pull request #2921: KAFKA-5124: autocommit reset earliest fixes race c...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2921 KAFKA-5124: autocommit reset earliest fixes race condition Fixes `org.apache.kafka.streams.integration.utils.IntegrationTestUtils#readKeyValues` potentially starting to `poll` for stream

[jira] [Commented] (KAFKA-5124) shouldInnerLeftJoin unit test fails

[ https://issues.apache.org/jira/browse/KAFKA-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984973#comment-15984973 ] ASF GitHub Bot commented on KAFKA-5124: --- GitHub user original-brownbear opened a pul

[jira] [Commented] (KAFKA-5124) shouldInnerLeftJoin unit test fails

[ https://issues.apache.org/jira/browse/KAFKA-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984980#comment-15984980 ] Armin Braun commented on KAFKA-5124: [~mjsax] I think the same fix I just added here

[jira] [Comment Edited] (KAFKA-5124) shouldInnerLeftJoin unit test fails

[ https://issues.apache.org/jira/browse/KAFKA-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15984980#comment-15984980 ] Armin Braun edited comment on KAFKA-5124 at 4/26/17 3:17 PM: -

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

A comment on the PR pointed out the advantages of a relatively minor adjustment to the method org.apache.kafka.streams.processor.addGlobalStore. It should take a StateStoreSupplier" type as the first argument, not a StateStore. Note that one can obtain a StateStore by calling the .get() method

Kafka Connect and Partitions

I've defined several Kafka Connect tasks via the tasks.max property to process a set of topics. Initially I set the partitions on the topics to 1 and partitioned the topics across the tasks programmatically so that each task processed a subset of the topics (or so I thought ...). I then noticed

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985043#comment-15985043 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] Thanks for confirming. Can

[jira] [Created] (KAFKA-5128) TransactionCoordinator - Check inter broker protocol and message format and raise errors if incompatible

Damian Guy created KAFKA-5128: - Summary: TransactionCoordinator - Check inter broker protocol and message format and raise errors if incompatible Key: KAFKA-5128 URL: https://issues.apache.org/jira/browse/KAFKA-5128

[jira] [Created] (KAFKA-5129) TransactionCoordinator - Add ACL check for each request

Damian Guy created KAFKA-5129: - Summary: TransactionCoordinator - Add ACL check for each request Key: KAFKA-5129 URL: https://issues.apache.org/jira/browse/KAFKA-5129 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-5128) TransactionCoordinator - Check inter broker protocol and message format and raise errors if incompatible

[ https://issues.apache.org/jira/browse/KAFKA-5128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5128: -- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5059 > TransactionCoordinator - Check inter broke

Re: Kafka-Streams: Cogroup

Thank you for your reply. I have attached my first attempt at writing a KIP and I was wondering if you could review it and share your thoughts. Going forward I would like to create this KIP. I was wondering whom I should ask to get the necessary permissions on the wiki. Username: winkelman.kyle

[jira] [Created] (KAFKA-5130) Change InterBrokerSendThread to use a Queue per broker

Damian Guy created KAFKA-5130: - Summary: Change InterBrokerSendThread to use a Queue per broker Key: KAFKA-5130 URL: https://issues.apache.org/jira/browse/KAFKA-5130 Project: Kafka Issue Type: Su

[jira] [Assigned] (KAFKA-5063) Flaky ResetIntegrationTest.testReprocessingFromScratchAfterResetWithIntermediateUserTopic

[ https://issues.apache.org/jira/browse/KAFKA-5063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-5063: -- Assignee: (was: Matthias J. Sax) > Flaky > ResetIntegrationTest.testReprocessingFr

[jira] [Assigned] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-4222: -- Assignee: (was: Matthias J. Sax) > Transient failure in QueryableStateIntegrationTe

[jira] [Updated] (KAFKA-5129) TransactionCoordinator - Add ACL check for each request

[ https://issues.apache.org/jira/browse/KAFKA-5129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-5129: -- Issue Type: Sub-task (was: Bug) Parent: KAFKA-5059 > TransactionCoordinator - Add ACL check for

[jira] [Created] (KAFKA-5131) WriteTxnMarkers and complete commit/abort on partition immigration

Damian Guy created KAFKA-5131: - Summary: WriteTxnMarkers and complete commit/abort on partition immigration Key: KAFKA-5131 URL: https://issues.apache.org/jira/browse/KAFKA-5131 Project: Kafka I

[jira] [Created] (KAFKA-5132) Abort long running transactions

Damian Guy created KAFKA-5132: - Summary: Abort long running transactions Key: KAFKA-5132 URL: https://issues.apache.org/jira/browse/KAFKA-5132 Project: Kafka Issue Type: Sub-task Repo

Re: Kafka Connect and Partitions

Hi, I'll need a bit more detail to help :) Are you writing a connector or trying to use an existing one? If existing, which connector? Is it source or sink? Here are few things I'd look at when debugging: * Is the connector reading from the topic you think you are reading? * Do you actually have

Re: [VOTE] KIP-112 - Handle disk failure for JBOD

+1 Discussed a few edits/improvements with Dong. - Rather than a blanket (Error != None) condition for detecting offline replicas you probably want a storage exception-specific error code. - Definitely in favor of improvement #7 and it shouldn’t be too hard to do. When bouncing with a log direct

[GitHub] kafka pull request #2922: KAFKA-5108: Add support for reading PID snapshot f...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2922 KAFKA-5108: Add support for reading PID snapshot files to DumpLogSegments You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFK

[jira] [Commented] (KAFKA-5108) Add support for reading PID snapshot files to DumpLogSegments

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

[jira] [Commented] (KAFKA-4202) Facing error while trying to create the Producer.

[ https://issues.apache.org/jira/browse/KAFKA-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985298#comment-15985298 ] Mohammed Naseer Khan commented on KAFKA-4202: - resetting the classpath worked

Re: [VOTE] KIP-112 - Handle disk failure for JBOD

Thanks for the vote! Discussed with Joel offline. I have updated the KIP to specify that controller will consider a replica to be offline if KafkaStorageException is specified for the replica in the LeaderAndIsrResponse. The other two improvements may be done in the future KIP. On Wed, Apr 26,

Re: [DISCUSS] KIP-112: Handle disk failure for JBOD

Hey Jun, Ismael, Thanks for all the review! Can you vote for KIP-112 if you are OK with the latest design doc? Thanks, Dong On Thu, Mar 30, 2017 at 3:29 PM, Dong Lin wrote: > Hi all, > > Thanks for all the comments. I am going to open the voting thread if > there is no further concern with the

Re: [VOTE] 0.10.2.1 RC3

Hi, Gwen, Thanks for doing the release. +1 from me. Jun On Fri, Apr 21, 2017 at 9:56 AM, Gwen Shapira wrote: > Hello Kafka users, developers, friends, romans, countrypersons, > > This is the fourth (!) candidate for release of Apache Kafka 0.10.2.1. > > It is a bug fix release, so we have lots

Re: [VOTE] 0.10.2.1 RC3

+1 (binding) Validated unit tests, quickstarts, connect, signatures On Wed, Apr 26, 2017 at 11:30 AM, Guozhang Wang wrote: > +1 > > Verified unit test on source, and quick start on binary (Scala 2.12 only). > > > Guozhang > > > On Wed, Apr 26, 2017 at 2:43 AM, Ian Duffy wrote: > > > +1 > > > >

[jira] [Resolved] (KAFKA-4202) Facing error while trying to create the Producer.

[ https://issues.apache.org/jira/browse/KAFKA-4202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4202. -- Resolution: Information Provided Closing as there was no follow up and it appear

Re: [VOTE] 0.10.2.1 RC3

+1 I compiled our (Rollout.io) kafka-stream project, run unit-tests and end-to-end tests (against streams 0.10.2.1 and broker 0.10.1.1) Everything works as expected On Wed, Apr 26, 2017 at 10:05 PM, Gwen Shapira wrote: > +1 (binding) > > Validated unit tests, quickstarts, connect, signatures >

Re: [VOTE] 0.10.2.1 RC3

Vote summary: +1: 6 (3 binding) - Eno, Ian, Guozhang, Jun, Gwen and Shimi 0: 0 -1: 0 W00t! 72 hours passed and we have 3 binding +1! Thank you for playing "bugfix release". See you all at the next round :) I'll get our bug fixes out the door ASAP. Gwen On Wed, Apr 26, 2017 at 12:12 PM, Shimi K

[jira] [Resolved] (KAFKA-5124) shouldInnerLeftJoin unit test fails

[ https://issues.apache.org/jira/browse/KAFKA-5124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5124. -- Resolution: Fixed Issue resolved by pull request 2921 [https://github.com/apache/kafka/pull/2921

[GitHub] kafka pull request #2921: KAFKA-5124: autocommit reset earliest fixes race c...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2921 --- 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] [Commented] (KAFKA-5124) shouldInnerLeftJoin unit test fails

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

[GitHub] kafka pull request #2914: KAFKA-4994: Fix findbug warnings about OffsetStora...

GitHub user johnma14 reopened a pull request: https://github.com/apache/kafka/pull/2914 KAFKA-4994: Fix findbug warnings about OffsetStorageWriter OffsetStorageWriter is not a thread-safe class and should be accessed only from a Task's processing thread. The WorkerSourceTask clas

[GitHub] kafka pull request #2914: KAFKA-4994: Fix findbug warnings about OffsetStora...

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

[jira] [Commented] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

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

[jira] [Commented] (KAFKA-4994) Fix findbugs warning about OffsetStorageWriter#currentFlushId

[ https://issues.apache.org/jira/browse/KAFKA-4994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985435#comment-15985435 ] ASF GitHub Bot commented on KAFKA-4994: --- GitHub user johnma14 reopened a pull reques

[jira] [Commented] (KAFKA-5005) JoinIntegrationTest fails occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985483#comment-15985483 ] Armin Braun commented on KAFKA-5005: [~enothereska] may I "steal" this one from you? :

Re: [VOTE] 0.10.2.1 RC3

Quick update: I closed the release on JIRA and bumped the versions in github. Uploaded artifacts and released the jars in Maven. Waiting for everything to actually show up before I update the website and send the announcement. Expect something tonight or tomorrow morning. Gwen On Wed, Apr 26, 201

[jira] [Assigned] (KAFKA-5005) JoinIntegrationTest fails occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-5005: Assignee: Armin Braun (was: Eno Thereska) > JoinIntegrationTest fails occasionally > -

[jira] [Commented] (KAFKA-5005) JoinIntegrationTest fails occasionally

[ https://issues.apache.org/jira/browse/KAFKA-5005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985499#comment-15985499 ] Eno Thereska commented on KAFKA-5005: - [~original-brownbear] absolutely, thank you! >

[GitHub] kafka pull request #2922: KAFKA-5108: Add support for reading PID snapshot f...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2922 --- 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] [Commented] (KAFKA-5108) Add support for reading PID snapshot files to DumpLogSegments

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

[jira] [Resolved] (KAFKA-4976) DumpLogSegments should print the contents of the pid snapshot files

[ https://issues.apache.org/jira/browse/KAFKA-4976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4976. Resolution: Duplicate Oops. Didn't know we already had this. In any case, the patch was merg

[GitHub] kafka pull request #2849: KAFKA-5059: Implement Transactional Coordinator

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2849 --- 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] [Commented] (KAFKA-5059) Implement Transactional Coordinator

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

Re: [DISCUSS] KIP-120: Cleanup Kafka Streams builder API

Just a small correction to KIP-120: Changed it to use `Set` instead of `List` within `TopologyDescription` and highlighting that we use getters (added couple of `()`). Also moved `name` to interface `Node` as all nodes do have a name. Also note, that I updated `GlobalStore` -- it's more detailed

[jira] [Resolved] (KAFKA-4958) kafka.server.KafkaServerStartable - java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/KAFKA-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin P. McCabe resolved KAFKA-4958. Resolution: Not A Problem Correct me if I'm wrong, but this doesn't seem like a bug. New ve

[jira] [Commented] (KAFKA-4958) kafka.server.KafkaServerStartable - java.lang.OutOfMemoryError: Java heap space

[ https://issues.apache.org/jira/browse/KAFKA-4958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15985642#comment-15985642 ] Ismael Juma commented on KAFKA-4958: Yes, the log cleaner was enabled by default in 0.

[GitHub] kafka pull request #946: KAFKA-3248: AdminClient Blocks Forever in send Meth...

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

[jira] [Commented] (KAFKA-3248) AdminClient Blocks Forever in send Method

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

Jenkins build is back to normal : kafka-trunk-jdk8 #1456

See

[GitHub] kafka pull request #2923: MINOR: Fix a few transaction coordinator issues

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2923 MINOR: Fix a few transaction coordinator issues You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka hotfix-tc-issues Alternativel

[GitHub] kafka pull request #2918: 0.10.2

Github user jpi-atos closed the pull request at: https://github.com/apache/kafka/pull/2918 --- 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 en

[jira] [Commented] (KAFKA-5132) Abort long running transactions

[ https://issues.apache.org/jira/browse/KAFKA-5132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15986115#comment-15986115 ] Umesh Chaudhary commented on KAFKA-5132: Hi [~damianguy] , can I attempt this one?