[jira] [Assigned] (KAFKA-13109) WorkerSourceTask is not enforcing the errors.retry.timeout and errors.retry.delay.max.ms parameters in case of a RetriableException during task.poll()

[ https://issues.apache.org/jira/browse/KAFKA-13109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-13109: - Assignee: Sagar Rao > WorkerSourceTask is not enforcing the errors.retry.timeout and >

[jira] [Comment Edited] (KAFKA-7739) Kafka Tiered Storage

[ https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722119#comment-17722119 ] Satish Duggana edited comment on KAFKA-7739 at 5/14/23 2:19 AM: [~jeqo] 

[jira] [Assigned] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream

[ https://issues.apache.org/jira/browse/KAFKA-14954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana reassigned KAFKA-14954: -- Assignee: Abhijeet Kumar (was: Satish Duggana) > Use BufferPools to optimize

[jira] [Assigned] (KAFKA-14953) Add metrics for expiration of delayed remote fetch

[ https://issues.apache.org/jira/browse/KAFKA-14953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Satish Duggana reassigned KAFKA-14953: -- Assignee: Abhijeet Kumar (was: Satish Duggana) > Add metrics for expiration of

[GitHub] [kafka] vamossagar12 commented on pull request #13504: KAFKA-14750: Check if topic exists in WorkerSinkTask when committing offsets.

vamossagar12 commented on PR #13504: URL: https://github.com/apache/kafka/pull/13504#issuecomment-1546785355 Test failures seem unrelated. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka] Scanteianu commented on pull request #13455: KAFKA-14841 Handle callbacks to ConsumerRebalanceListener in MockConsumer

Scanteianu commented on PR #13455: URL: https://github.com/apache/kafka/pull/13455#issuecomment-1546748512 in past few builds, at least one of the builds passed (in this one it was jdk 17 and scala 2.13).

[GitHub] [kafka] bmscomp commented on pull request #13662: MINOR: Upgrade Jackson dependencies to version 2.15.0

bmscomp commented on PR #13662: URL: https://github.com/apache/kafka/pull/13662#issuecomment-1546745756 @ijuma the PR is updated , I managed to keep only modifications related to the upgrade of `Jackson` version to `2.15.0`, I'll make another separate PR related to clean-ups --

[GitHub] [kafka] satishd commented on a diff in pull request #13689: KAFKA-14975: Wait for TopicBasedRemoteLogMetadataManager.ensureInitializedAndNotClosed to initialize rather than throwing

satishd commented on code in PR #13689: URL: https://github.com/apache/kafka/pull/13689#discussion_r1193008914 ## storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java: ## @@ -489,14 +498,28 @@ public boolean

[GitHub] [kafka] satishd commented on pull request #13689: KAFKA-14975: Wait for TopicBasedRemoteLogMetadataManager.ensureInitializedAndNotClosed to initialize rather than throwing

satishd commented on PR #13689: URL: https://github.com/apache/kafka/pull/13689#issuecomment-1546701743 Sorry, missed this PR notification earlier. Replied a comment [here](https://github.com/apache/kafka/pull/13689#discussion_r1193008914). -- This is an automated message from the

[jira] [Commented] (KAFKA-13156) KafkaStatusBackingStore making incorrect assumption about order of task and connector delete events

[ https://issues.apache.org/jira/browse/KAFKA-13156?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722367#comment-17722367 ] Sagar Rao commented on KAFKA-13156: --- hey [~ChrisEgerton] , I assigned this to myself ( I hope that's

[jira] [Assigned] (KAFKA-13156) KafkaStatusBackingStore making incorrect assumption about order of task and connector delete events

[ https://issues.apache.org/jira/browse/KAFKA-13156?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao reassigned KAFKA-13156: - Assignee: Sagar Rao (was: Chris Egerton) > KafkaStatusBackingStore making incorrect

[GitHub] [kafka] vamossagar12 commented on pull request #13608: KAFKA-14884: Include check transaction is still ongoing right before append

vamossagar12 commented on PR #13608: URL: https://github.com/apache/kafka/pull/13608#issuecomment-1546652807 hey @jolshan , looks like this PR got tagged in a Connect related JIRa https://issues.apache.org/jira/browse/KAFKA-14844. -- This is an automated message from the Apache Git

[jira] [Updated] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao updated KAFKA-14956: -- Labels: flaky-test (was: ) > Flaky test >

[jira] [Updated] (KAFKA-14956) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest#testGetSinkConnectorOffsetsDifferentKafkaClusterTargeted

[ https://issues.apache.org/jira/browse/KAFKA-14956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao updated KAFKA-14956: -- Component/s: KafkaConnect > Flaky test >

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #13504: KAFKA-14750: Check if topic exists in WorkerSinkTask when committing offsets.

vamossagar12 commented on code in PR #13504: URL: https://github.com/apache/kafka/pull/13504#discussion_r1192983841 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java: ## @@ -700,9 +714,28 @@ private class HandleRebalance implements

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #13504: KAFKA-14750: Check if topic exists in WorkerSinkTask when committing offsets.

vamossagar12 commented on code in PR #13504: URL: https://github.com/apache/kafka/pull/13504#discussion_r1192983825 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java: ## @@ -700,9 +714,28 @@ private class HandleRebalance implements

[GitHub] [kafka] vamossagar12 commented on a diff in pull request #13504: KAFKA-14750: Check if topic exists in WorkerSinkTask when committing offsets.

vamossagar12 commented on code in PR #13504: URL: https://github.com/apache/kafka/pull/13504#discussion_r1192983808 ## connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java: ## @@ -145,6 +154,10 @@ public WorkerSinkTask(ConnectorTaskId id,

[jira] [Updated] (KAFKA-14971) Flaky Test org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest#testSyncTopicConfigs

[ https://issues.apache.org/jira/browse/KAFKA-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Rao updated KAFKA-14971: -- Labels: flaky-test mirror-maker (was: ) > Flaky Test >

[jira] [Created] (KAFKA-14997) JmxToolTest failing with initializationError

Sagar Rao created KAFKA-14997: - Summary: JmxToolTest failing with initializationError Key: KAFKA-14997 URL: https://issues.apache.org/jira/browse/KAFKA-14997 Project: Kafka Issue Type: Bug

[GitHub] [kafka] vamossagar12 commented on pull request #13453: KAFKA-12525: Ignoring Stale status statuses when reading from Status …

vamossagar12 commented on PR #13453: URL: https://github.com/apache/kafka/pull/13453#issuecomment-1546645439 The test failures now aren't related to Connect(only one related to MM but that seems to be flaky and have notified Greg about it). @C0urante , when you have some bandwidth, would

[GitHub] [kafka] omkreddy commented on pull request #13717: KAFKA-14994: jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

omkreddy commented on PR #13717: URL: https://github.com/apache/kafka/pull/13717#issuecomment-1546629332 Merged to 3.5 and 3.4 branches. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[jira] [Updated] (KAFKA-14994) jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

[ https://issues.apache.org/jira/browse/KAFKA-14994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-14994: -- Fix Version/s: 3.5.0 3.4.1 (was: 3.6.0) > jose4j is

[GitHub] [kafka] mimaison commented on pull request #13717: KAFKA-14994: jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

mimaison commented on PR #13717: URL: https://github.com/apache/kafka/pull/13717#issuecomment-1546626351 I think we could backport this to 3.5 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the

[GitHub] [kafka] chia7712 opened a new pull request, #13718: MINOR: move ControlRecordTest to correct directory

chia7712 opened a new pull request, #13718: URL: https://github.com/apache/kafka/pull/13718 one line fix :) the package of `ControlRecordTest` is `org.apache.kafka.raft` but it is located at incorrect folder `org/apache/kafka`. ### Committer Checklist (excluded from commit

[jira] [Resolved] (KAFKA-14994) jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

[ https://issues.apache.org/jira/browse/KAFKA-14994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Atul Sharma resolved KAFKA-14994. - Resolution: Fixed > jose4j is vulnerable to CVE- Improper Cryptographic Algorithm >

[GitHub] [kafka] LinShunKang commented on pull request #12685: KAFKA-14945: Add Serializer#serializeToByteBuffer() to reduce memory copying

LinShunKang commented on PR #12685: URL: https://github.com/apache/kafka/pull/12685#issuecomment-1546596937 > LGTM overall. I wish the murmur code was somehow generalized so that there wasn't two versions of it. We'll just have to be careful that it doesn't diverge. Thank you for

[GitHub] [kafka] tamama commented on pull request #12447: KAFKA-14124: improve quorum controller fault handling

tamama commented on PR #12447: URL: https://github.com/apache/kafka/pull/12447#issuecomment-1546596309 Hi @cmccabe @mumrah - Our production cluster (Apache Kafka 3.3.1) is having occasional problem with KRaft Quorum controller - A little search brings me to this PR. - A quick

[GitHub] [kafka] erikvanoosten commented on a diff in pull request #13678: KAFKA-10337: await async commits in commitSync even if no offsets given

erikvanoosten commented on code in PR #13678: URL: https://github.com/apache/kafka/pull/13678#discussion_r1192944987 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java: ## @@ -1223,6 +1233,26 @@ public void

[GitHub] [kafka] erikvanoosten commented on a diff in pull request #13678: KAFKA-10337: await async commits in commitSync even if no offsets given

erikvanoosten commented on code in PR #13678: URL: https://github.com/apache/kafka/pull/13678#discussion_r1192944903 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java: ## @@ -1223,6 +1233,26 @@ public void

[GitHub] [kafka] LinShunKang commented on a diff in pull request #12685: KAFKA-14945: Add Serializer#serializeToByteBuffer() to reduce memory copying

LinShunKang commented on code in PR #12685: URL: https://github.com/apache/kafka/pull/12685#discussion_r1192944264 ## clients/src/main/java/org/apache/kafka/clients/producer/Partitioner.java: ## @@ -31,13 +34,27 @@ public interface Partitioner extends Configurable, Closeable {

[GitHub] [kafka] LinShunKang commented on a diff in pull request #12685: KAFKA-14945: Add Serializer#serializeToByteBuffer() to reduce memory copying

LinShunKang commented on code in PR #12685: URL: https://github.com/apache/kafka/pull/12685#discussion_r1192944064 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -1383,9 +1386,13 @@ private ClusterResourceListeners

[jira] [Updated] (KAFKA-14994) jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

[ https://issues.apache.org/jira/browse/KAFKA-14994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-14994: -- Fix Version/s: 3.6.0 > jose4j is vulnerable to CVE- Improper Cryptographic Algorithm >

[GitHub] [kafka] omkreddy merged pull request #13717: KAFKA-14994: jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

omkreddy merged PR #13717: URL: https://github.com/apache/kafka/pull/13717 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[GitHub] [kafka] omkreddy commented on pull request #13717: KAFKA-14994: jose4j is vulnerable to CVE- Improper Cryptographic Algorithm

omkreddy commented on PR #13717: URL: https://github.com/apache/kafka/pull/13717#issuecomment-1546563746 Test failures are unrelated: Build / JDK 11 and Scala 2.13 / testRackAwareRangeAssignor() – integration.kafka.server.FetchFromFollowerIntegrationTest 22s Build / JDK 11 and

[jira] [Commented] (KAFKA-14995) Automate asf.yaml collaborators refresh

[ https://issues.apache.org/jira/browse/KAFKA-14995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17722334#comment-17722334 ] David Jacot commented on KAFKA-14995: - There is a group in github with all the committers: