[jira] [Commented] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628201#comment-16628201 ] Dong Lin commented on KAFKA-7441: - PR can be found at [https://github.com/apache/kafka/pull/5694] >

[jira] [Updated] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7441: Fix Version/s: 2.1.0 > Allow LogCleanerManager.resumeCleaning() to be used concurrently >

[jira] [Updated] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

[ https://issues.apache.org/jira/browse/KAFKA-7441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-7441: Reporter: xiongqi wu (was: Dong Lin) > Allow LogCleanerManager.resumeCleaning() to be used concurrently >

[jira] [Created] (KAFKA-7441) Allow LogCleanerManager.resumeCleaning() to be used concurrently

Dong Lin created KAFKA-7441: --- Summary: Allow LogCleanerManager.resumeCleaning() to be used concurrently Key: KAFKA-7441 URL: https://issues.apache.org/jira/browse/KAFKA-7441 Project: Kafka Issue

[jira] [Resolved] (KAFKA-7216) Exception while running kafka-acls.sh from 1.0 env on target Kafka env with 1.1.1

[ https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-7216. Resolution: Fixed Fix Version/s: 2.1.0 2.0.1 1.1.2

[jira] [Commented] (KAFKA-7216) Exception while running kafka-acls.sh from 1.0 env on target Kafka env with 1.1.1

[ https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628113#comment-16628113 ] ASF GitHub Bot commented on KAFKA-7216: --- junrao closed pull request #5679: KAFKA-7216: Ignore

[jira] [Commented] (KAFKA-7216) Exception while running kafka-acls.sh from 1.0 env on target Kafka env with 1.1.1

[ https://issues.apache.org/jira/browse/KAFKA-7216?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628111#comment-16628111 ] ASF GitHub Bot commented on KAFKA-7216: --- junrao closed pull request #5680: KAFKA-7216: Ignore

[jira] [Commented] (KAFKA-7322) Fix race condition between log cleaner thread and log retention thread when topic cleanup policy is updated

[ https://issues.apache.org/jira/browse/KAFKA-7322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16628093#comment-16628093 ] ASF GitHub Bot commented on KAFKA-7322: --- xiowu0 opened a new pull request #5694: KAFKA-7322; This

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627924#comment-16627924 ] Matthias J. Sax commented on KAFKA-7061: I just updated the Jira – the KIP was not accepted yet,

[jira] [Updated] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7061: --- Fix Version/s: (was: 2.1.0) 2.2.0 > Enhanced log compaction >

[jira] [Updated] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-7061: --- Labels: kip (was: ) > Enhanced log compaction > --- > >

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627902#comment-16627902 ] ASF GitHub Bot commented on KAFKA-7223: --- vvcephei opened a new pull request #5693: KAFKA-7223:

[jira] [Commented] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data

[ https://issues.apache.org/jira/browse/KAFKA-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627901#comment-16627901 ] Matthias J. Sax commented on KAFKA-7432: As you point out, that you don't care about sync vs

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627891#comment-16627891 ] ASF GitHub Bot commented on KAFKA-7223: --- guozhangwang closed pull request #5687: KAFKA-7223: add

[jira] [Commented] (KAFKA-7223) KIP-328: Add in-memory Suppression

[ https://issues.apache.org/jira/browse/KAFKA-7223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627888#comment-16627888 ] ASF GitHub Bot commented on KAFKA-7223: --- vvcephei closed pull request #5688: KAFKA-7223: Part 3

[jira] [Updated] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-3190: Fix Version/s: (was: 2.1.0) 2.2.0 > KafkaProducer should not invoke callback in

[jira] [Commented] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627813#comment-16627813 ] Dong Lin commented on KAFKA-3190: - Since there has been no activity on the PR for several months, moving

[jira] [Created] (KAFKA-7440) Use leader epoch in consumer fetch requests

Jason Gustafson created KAFKA-7440: -- Summary: Use leader epoch in consumer fetch requests Key: KAFKA-7440 URL: https://issues.apache.org/jira/browse/KAFKA-7440 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627580#comment-16627580 ] Bertus Greeff commented on KAFKA-7061: -- There is discussion of this KIP on the Kafka Dev mailing

[jira] [Commented] (KAFKA-7403) Offset commit failure after upgrading brokers past KIP-211/KAFKA-4682

[ https://issues.apache.org/jira/browse/KAFKA-7403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627571#comment-16627571 ] ASF GitHub Bot commented on KAFKA-7403: --- hachikuji closed pull request #5690: KAFKA-7403: Follow-up

[jira] [Commented] (KAFKA-7438) Replace EasyMock and PowerMock with Mockito

[ https://issues.apache.org/jira/browse/KAFKA-7438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627541#comment-16627541 ] ASF GitHub Bot commented on KAFKA-7438: --- ijuma opened a new pull request #5691: KAFKA-7438: Replace

[jira] [Created] (KAFKA-7439) Replace EasyMock and PowerMock with Mockito in clients module

Ismael Juma created KAFKA-7439: -- Summary: Replace EasyMock and PowerMock with Mockito in clients module Key: KAFKA-7439 URL: https://issues.apache.org/jira/browse/KAFKA-7439 Project: Kafka

[jira] [Created] (KAFKA-7438) Replace EasyMock and PowerMock with Mockito

Ismael Juma created KAFKA-7438: -- Summary: Replace EasyMock and PowerMock with Mockito Key: KAFKA-7438 URL: https://issues.apache.org/jira/browse/KAFKA-7438 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-4107) Support offset reset capability in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627415#comment-16627415 ] Alex Ott commented on KAFKA-4107: - It would be really nice to have more high-level version of such tool

[jira] [Commented] (KAFKA-6268) Tools should not swallow exceptions like resolving network names

[ https://issues.apache.org/jira/browse/KAFKA-6268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627397#comment-16627397 ] Antony Stubbs commented on KAFKA-6268: -- If either a failed socket response happens or an observed

[jira] [Resolved] (KAFKA-5066) KafkaMetricsConfig properties and description notably missing from documentation

[ https://issues.apache.org/jira/browse/KAFKA-5066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5066. -- Resolution: Fixed > KafkaMetricsConfig properties and description notably missing from >

[jira] [Resolved] (KAFKA-3532) add principal.builder.class that can extract user from a field

[ https://issues.apache.org/jira/browse/KAFKA-3532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3532. -- Resolution: Duplicate This will be fixed be part of KAFKA-5462/KIP-371 > add principal.builder.class

[jira] [Commented] (KAFKA-7432) API Method on Kafka Streams for processing chunks/batches of data

[ https://issues.apache.org/jira/browse/KAFKA-7432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16627144#comment-16627144 ] sam commented on KAFKA-7432: [~mjsax] [~vvcephei] OK let's merge them if you think that's a good idea.  I

[jira] [Commented] (KAFKA-3268) Refactor existing CLI scripts to use KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-3268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626992#comment-16626992 ] Viktor Somogyi commented on KAFKA-3268: --- Published KIP-375 about TopicCommand. I'd be happy if

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626990#comment-16626990 ] Andy Pook commented on KAFKA-7061: -- Hey, could I ask for someone to comment on the status of this? This

[jira] [Assigned] (KAFKA-6794) Support for incremental replica reassignment

[ https://issues.apache.org/jira/browse/KAFKA-6794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Viktor Somogyi reassigned KAFKA-6794: - Assignee: Viktor Somogyi (was: Sandor Murakozi) > Support for incremental replica

[jira] [Updated] (KAFKA-6161) Add default implementation to close() and configure() for Serializer, Deserializer and Serde

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-6161: --- Labels: kip (was: needs-kip) > Add default implementation to close() and configure() for

[jira] [Commented] (KAFKA-7412) Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running

[ https://issues.apache.org/jira/browse/KAFKA-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16626825#comment-16626825 ] Michal Turek commented on KAFKA-7412: - Hmm, I have just tried to repeat it multiple times with fresh

[jira] [Updated] (KAFKA-7412) Bug prone response from producer.send(ProducerRecord, Callback) if Kafka broker is not running

[ https://issues.apache.org/jira/browse/KAFKA-7412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michal Turek updated KAFKA-7412: Attachment: both_metadata_and_exception.png > Bug prone response from