[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YaYun Wang updated KAFKA-15074:
---
Description:
I got ?? "Fetch position FetchPosition{offset=42574305,
offsetEpoch=Optional[2214],
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1222426539
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -980,6 +1006,25 @@ class UnifiedLog(@volatile var logStartOffset: Long,
if (duplicateBatch.isPresent)
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YaYun Wang updated KAFKA-15074:
---
Description:
I got ?? "Fetch position FetchPosition{offset=42574305,
offsetEpoch=Optional[2214],
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730365#comment-17730365
]
YaYun Wang edited comment on KAFKA-15074 at 6/8/23 3:30 AM:
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YaYun Wang updated KAFKA-15074:
---
Description:
I ??got Fetch position FetchPosition{offset=42574305,
offsetEpoch=Optional[2214],
cur
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730365#comment-17730365
]
YaYun Wang commented on KAFKA-15074:
And here is my debug logs of kafka-client:
202
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730360#comment-17730360
]
YaYun Wang commented on KAFKA-15074:
*Here is my code:*
@KafkaListener(
topics = "m
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YaYun Wang updated KAFKA-15074:
---
Description:
I ??got Fetch position FetchPosition{offset=42574305,
offsetEpoch=Optional[2214],
cur
[
https://issues.apache.org/jira/browse/KAFKA-15074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YaYun Wang updated KAFKA-15074:
---
Description:
I ??got Fetch position FetchPosition{offset=42574305,
offsetEpoch=Optional[2214],
cur
YaYun Wang created KAFKA-15074:
--
Summary: offset out of range for partition xxx, resetting offset
Key: KAFKA-15074
URL: https://issues.apache.org/jira/browse/KAFKA-15074
Project: Kafka
Issue Typ
wcarlson5 commented on code in PR #13756:
URL: https://github.com/apache/kafka/pull/13756#discussion_r1222332377
##
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java:
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the Apache Softw
mumrah opened a new pull request, #13827:
URL: https://github.com/apache/kafka/pull/13827
This patch uses a Github workflow to mark inactive PRs with the `stale`
label. The workflow uses the ["stale" action](https://github.com/actions/stale)
which has many features including a number of fil
David Arthur created KAFKA-15073:
Summary: Automation for old/inactive PRs
Key: KAFKA-15073
URL: https://issues.apache.org/jira/browse/KAFKA-15073
Project: Kafka
Issue Type: Improvement
jolshan commented on code in PR #13812:
URL: https://github.com/apache/kafka/pull/13812#discussion_r1222312423
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/ReplicatedGroupCoordinator.java:
##
@@ -0,0 +1,202 @@
+/*
+ * Licensed to the Apache Software Foun
jolshan commented on PR #13796:
URL: https://github.com/apache/kafka/pull/13796#issuecomment-1581669973
> No, we can't - it all depends on the retries and the delivery timeout.
Do you think that causes a problem?
I guess I just need to clarify what retried batches are here -- is the
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581658284
> I'm not sure I follow. Are you saying that the test would set the thread
local before running? So a single thread may set itself back and forth within
the suite? (If you have a commit
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581633134
> Are you saying that the test would set the thread local before running? So
a single thread may set itself back and forth within the suite?
Precisely. That's in effect what it doe
pjpringle commented on PR #12540:
URL: https://github.com/apache/kafka/pull/12540#issuecomment-1581567216
Is this bug eos specific given the title? Looking at the fix I dont believe
it is. I have been seeing similar stale state issues on rebalance in a non eos
setup but with stand by replic
jolshan commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581564571
> No, the test method would need to specifically mark its thread as wanting
to poison the thread or not before running the rest of the test. In the
TransactionManagerTest, there was only
vcrfxia commented on code in PR #13756:
URL: https://github.com/apache/kafka/pull/13756#discussion_r107444
##
streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBufferTest.java:
##
@@ -0,0 +1,169 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/KAFKA-15060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-15060:
-
Description: (was: Fix Admin.describeFeatures, which was accidentally
broken by KAFKA-15007.
cmccabe opened a new pull request, #13826:
URL: https://github.com/apache/kafka/pull/13826
This PR expands the scope of ApiVersionManager a bit to include returning
the current MetadataVersion and features that are in effect. This is useful in
general because that information needs to be re
[
https://issues.apache.org/jira/browse/KAFKA-15060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-15060:
-
Summary: Fix the ApiVersionManager interface (was: Fix
Admin.describeFeatures)
> Fix the ApiVe
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r102869
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222198170
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222177376
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222175645
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222169738
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222158858
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222148781
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
junrao commented on code in PR #13815:
URL: https://github.com/apache/kafka/pull/13815#discussion_r1222142092
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java:
##
@@ -0,0 +1,295 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222140560
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
jlprat commented on PR #13824:
URL: https://github.com/apache/kafka/pull/13824#issuecomment-1581463300
Tests failures seem all unrelated and I created the corresponding Jira
tickets for the ones I couldn't fine an already existing one:
https://issues.apache.org/jira/browse/KAFKA-15070,
h
Josep Prat created KAFKA-15072:
--
Summary: Flaky test
MirrorConnectorsIntegrationExactlyOnceTest.testReplicationWithEmptyPartition
Key: KAFKA-15072
URL: https://issues.apache.org/jira/browse/KAFKA-15072
P
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222117410
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntimeTest.java:
##
@@ -0,0 +1,803 @@
+/*
+ * Licensed to the Apache Software
[
https://issues.apache.org/jira/browse/KAFKA-15071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-15071:
---
Component/s: core
> Flaky test kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection
>
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222115234
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/MultiThreadedEventProcessor.java:
##
@@ -39,7 +40,7 @@ public class MultiThreadedEventProc
[
https://issues.apache.org/jira/browse/KAFKA-15071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-15071:
---
Affects Version/s: 3.5.0
> Flaky test kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElec
[
https://issues.apache.org/jira/browse/KAFKA-14971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730272#comment-17730272
]
Josep Prat commented on KAFKA-14971:
Another occurrence:
https://ci-builds.apache.o
junrao commented on code in PR #13797:
URL: https://github.com/apache/kafka/pull/13797#discussion_r1221908399
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java:
##
@@ -106,4 +114,17 @@ private boolean process(final OffsetF
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581446668
> ThreadLocal variables are not as frequently used in Kafka, but I can see a
potential argument for usage here. One tricky part about thread locals is
testing. Any ideas on how we could
[
https://issues.apache.org/jira/browse/KAFKA-15020?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730271#comment-17730271
]
Josep Prat commented on KAFKA-15020:
Seen this test failing with a different error:
jolshan commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581443881
ThreadLocal variables are not as frequently used in Kafka, but I can see a
potential argument for usage here. One tricky part about thread locals is
testing. Any ideas on how we could do
[
https://issues.apache.org/jira/browse/KAFKA-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck resolved KAFKA-14539.
-
Resolution: Fixed
> Simplify StreamsMetadataState by replacing the Cluster metadata with
> part
[
https://issues.apache.org/jira/browse/KAFKA-14539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-14539:
Fix Version/s: 3.6.0
> Simplify StreamsMetadataState by replacing the Cluster metadata with
> par
Josep Prat created KAFKA-15071:
--
Summary: Flaky test
kafka.admin.LeaderElectionCommandTest.testPreferredReplicaElection for Type=ZK,
MetadataVersion=3.5-IV2, Security=PLAINTEXT
Key: KAFKA-15071
URL: https://issues.a
Josep Prat created KAFKA-15070:
--
Summary: Flaky test
kafka.log.LogCleanerParameterizedIntegrationTest.testCleansCombinedCompactAndDeleteTopic
for codec zstd
Key: KAFKA-15070
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/KAFKA-15052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730264#comment-17730264
]
Josep Prat commented on KAFKA-15052:
Adding another occurrence:
https://ci-builds.a
gharris1727 commented on PR #13313:
URL: https://github.com/apache/kafka/pull/13313#issuecomment-1581417136
@ijuma Here are the results of my local test runs of test suites which use
LATEST_0_8_2 and VerifiableProducer:
* test_verifiable_producer.py: 25/25 PASS
* compatibility_test
[
https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730263#comment-17730263
]
Josep Prat commented on KAFKA-8073:
---
I can see this still failing:
https://ci-builds.a
bbejeck commented on PR #13751:
URL: https://github.com/apache/kafka/pull/13751#issuecomment-1581399670
merged #13751 into trunk
--
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 comme
bbejeck merged PR #13751:
URL: https://github.com/apache/kafka/pull/13751
--
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: jira-unsubscr...@kafka.apache.
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581369789
@jolshan here's the basic idea:
```diff
diff --git
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
b/clients/src/main/java/org/apache/kafka/clie
kirktrue commented on PR #13591:
URL: https://github.com/apache/kafka/pull/13591#issuecomment-1581356873
@jolshan The more I look at the code, the more I dislike it. Having the
extra `CallingThread` parameter to distinguish application threads from the
`Sender` thread is just... ugly.
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222035271
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorEvent.java:
##
@@ -16,21 +16,23 @@
*/
package org.apache.kafka.coordinator.g
kirktrue commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1222035054
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -977,18 +1058,20 @@ void handleCoordinatorReady() {
kirktrue commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1222034380
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -471,9 +547,9 @@ synchronized void
requestEpochBumpForPartition(To
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222033908
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -0,0 +1,1009 @@
+/*
+ * Licensed to the Apache Software Fou
jolshan commented on code in PR #13795:
URL: https://github.com/apache/kafka/pull/13795#discussion_r1222029897
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java:
##
@@ -0,0 +1,1040 @@
+/*
+ * Licensed to the Apache Software Fou
mumrah commented on code in PR #13823:
URL: https://github.com/apache/kafka/pull/13823#discussion_r1222020155
##
server-common/src/test/java/org/apache/kafka/server/util/MockTime.java:
##
@@ -27,15 +23,21 @@
* 1. This has an associated scheduler instance for managing backgroun
kirktrue commented on code in PR #13591:
URL: https://github.com/apache/kafka/pull/13591#discussion_r1222019325
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -609,14 +686,15 @@ public synchronized void
handleCompletedBatch(P
dajac commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221998443
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -579,6 +579,28 @@ class UnifiedLog(@volatile var logStartOffset: Long,
result
}
+ /**
+ * Maybe crea
mumrah closed pull request #13825: DO NOT MERGE: Testing a Github action
URL: https://github.com/apache/kafka/pull/13825
--
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 unsu
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221986657
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -579,6 +579,28 @@ class UnifiedLog(@volatile var logStartOffset: Long,
result
}
+ /**
+ * Maybe cr
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221910510
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -980,6 +1006,26 @@ class UnifiedLog(@volatile var logStartOffset: Long,
if (duplicateBatch.isPresent
wcarlson5 commented on code in PR #13751:
URL: https://github.com/apache/kafka/pull/13751#discussion_r1221950345
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java:
##
@@ -308,12 +308,17 @@ public synchronized KeyQueryMetadata
getKe
yashmayya commented on PR #13530:
URL: https://github.com/apache/kafka/pull/13530#issuecomment-1581235501
> which is oddly not showing up on the GitHub PR UI, although it does show
up on my fork's branch which this PR is created from
https://www.githubstatus.com/incidents/1g1gkh0qpyvs
yashmayya commented on code in PR #13818:
URL: https://github.com/apache/kafka/pull/13818#discussion_r1221937078
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -1587,10 +1595,11 @@ private boolean alterConnectorOffsets
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221909838
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -579,6 +579,28 @@ class UnifiedLog(@volatile var logStartOffset: Long,
result
}
+ /**
+ * Maybe cr
mehbey commented on PR #13709:
URL: https://github.com/apache/kafka/pull/13709#issuecomment-1581221839
Hey @showuon , the
[KIP](https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation#KIP937)
for this pull request (PR) is published, and there have b
C0urante commented on code in PR #13818:
URL: https://github.com/apache/kafka/pull/13818#discussion_r1221916704
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java:
##
@@ -1320,89 +1338,188 @@ void alterSinkConnectorOffsets(String connName,
Connector c
C0urante commented on code in PR #13818:
URL: https://github.com/apache/kafka/pull/13818#discussion_r1221803692
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java:
##
@@ -374,19 +374,38 @@ public synchronized void connectorOffsets(
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221911516
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -2095,82 +2105,143 @@ class ReplicaManagerTest {
}
@Test
- def testVerificationForTran
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221910510
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -980,6 +1006,26 @@ class UnifiedLog(@volatile var logStartOffset: Long,
if (duplicateBatch.isPresent
jolshan commented on code in PR #13787:
URL: https://github.com/apache/kafka/pull/13787#discussion_r1221909838
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -579,6 +579,28 @@ class UnifiedLog(@volatile var logStartOffset: Long,
result
}
+ /**
+ * Maybe cr
yashmayya commented on PR #13530:
URL: https://github.com/apache/kafka/pull/13530#issuecomment-1581192139
> Modifying the status parts of the REST API seems less like introducing
further divergence and more like honestly reporting that existing divergence to
users.
Fair enough, I've
jolshan merged PR #13811:
URL: https://github.com/apache/kafka/pull/13811
--
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: jira-unsubscr...@kafka.apache.
dajac commented on PR #13823:
URL: https://github.com/apache/kafka/pull/13823#issuecomment-1581188466
@mimaison @showuon @dengziming Would one of you have time to review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/KAFKA-15056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730199#comment-17730199
]
Kirk True commented on KAFKA-15056:
---
[~tophei] is this fixed by
[KAFKA-13668|https://
[
https://issues.apache.org/jira/browse/KAFKA-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730195#comment-17730195
]
Kirk True commented on KAFKA-14445:
---
[~ocadaruma] my apologies, I didn't read your ini
[
https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-13531:
-
Attachment:
org.apache.kafka.streams.integration.NamedTopologyIntegrationTest.shouldRemoveOneNam
[
https://issues.apache.org/jira/browse/KAFKA-13531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730190#comment-17730190
]
John Roesler commented on KAFKA-13531:
--
Seen again while verifying the 3.5.0 releas
Greg Harris created KAFKA-15069:
---
Summary: Refactor scanning hierarchy out of DelegatingClassLoader
Key: KAFKA-15069
URL: https://issues.apache.org/jira/browse/KAFKA-15069
Project: Kafka
Issue
clolov commented on PR #13260:
URL: https://github.com/apache/kafka/pull/13260#issuecomment-1581120917
I have not, but I will aim to carry out the check in the upcoming days.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10337:
---
Assignee: Erik van Oosten (was: David Jacot)
> Wait for pending async commits in commitSyn
[
https://issues.apache.org/jira/browse/KAFKA-15051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17730156#comment-17730156
]
ASF GitHub Bot commented on KAFKA-15051:
C0urante opened a new pull request, #52
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10337:
---
Assignee: David Jacot
> Wait for pending async commits in commitSync() even if no offsets a
vamossagar12 commented on PR #13158:
URL: https://github.com/apache/kafka/pull/13158#issuecomment-1581026296
I see. TBH I haven't followed that migration off-late. I think there are
build failures as well which I haven't addressed yet.
--
This is an automated message from the Apache Git S
erikvanoosten commented on PR #13678:
URL: https://github.com/apache/kafka/pull/13678#issuecomment-1581020841
> @erikvanoosten It seems that you don't have an account for jira so I can't
assign the ticket to you. You should request one.
I do have an account. My Jira userid is erikvano
C0urante commented on PR #13803:
URL: https://github.com/apache/kafka/pull/13803#issuecomment-1581020451
@vvcephei haha, no worries! I'll leave Jenkins alone if I see you in the
neighborhood testing again 🙏
--
This is an automated message from the Apache Git Service.
To respond to the mes
C0urante merged PR #13803:
URL: https://github.com/apache/kafka/pull/13803
--
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: jira-unsubscr...@kafka.apache
C0urante commented on PR #13819:
URL: https://github.com/apache/kafka/pull/13819#issuecomment-1581002727
Ah, I hadn't noticed that this was only introduced in
https://github.com/apache/kafka/pull/13465. In that case, the good news is that
this bug hasn't made it into a release yet! And the
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10337.
-
Fix Version/s: 3.6.0
Resolution: Fixed
> Wait for pending async commits in commitSync() e
dajac commented on PR #13678:
URL: https://github.com/apache/kafka/pull/13678#issuecomment-1580998335
@erikvanoosten It seems that you don't have an account for jira so I can't
assign the ticket to you. You should request one.
--
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/KAFKA-10337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-10337:
---
Assignee: (was: Kirk True)
> Wait for pending async commits in commitSync() even if no
dajac merged PR #13678:
URL: https://github.com/apache/kafka/pull/13678
--
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: jira-unsubscr...@kafka.apache.or
vamossagar12 commented on PR #12306:
URL: https://github.com/apache/kafka/pull/12306#issuecomment-1580988777
Converting to draft. Need some time before I get to this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
vamossagar12 closed pull request #12485: KAFKA-14131: Adding InterruptException
when reading to end of Offseto…
URL: https://github.com/apache/kafka/pull/12485
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao reassigned KAFKA-14131:
-
Assignee: Sambhav Jain (was: Sagar Rao)
> KafkaBasedLog#readToLogEnd() may accciedently falls
C0urante commented on PR #13821:
URL: https://github.com/apache/kafka/pull/13821#issuecomment-1580969721
@gharris1727 can we start filing Jira tickets for these changes to
classloading logic? They're large enough that I don't think `MINOR` is
warranted anymore, and it'd be nice to have a pi
1 - 100 of 139 matches
Mail list logo
