showuon commented on PR #14116:
URL: https://github.com/apache/kafka/pull/14116#issuecomment-1666411942
Please let me know when ready for review. Thanks for the work!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
kamalcph commented on PR #14151:
URL: https://github.com/apache/kafka/pull/14151#issuecomment-1666405256
Not clear on this patch, will go another round of review.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
kamalcph commented on code in PR #14151:
URL: https://github.com/apache/kafka/pull/14151#discussion_r1284973824
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -134,6 +134,8 @@ public final class RemoteLogManagerConfig {
[
https://issues.apache.org/jira/browse/KAFKA-12890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751269#comment-17751269
]
Yang commented on KAFKA-12890:
--
Hi [~dajac] I know this issue and PR have been closed for
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15309:
Description:
The producer collects multiple records into batches, and a single record
spe
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15309:
Description:
The producer collects multiple records into batches, and a single record
spe
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15309:
Description:
The producer collects multiple records into batches, and a single record
spe
[
https://issues.apache.org/jira/browse/KAFKA-15309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15309:
Description:
The producer batches up multiple records into batches, and a single record
s
[
https://issues.apache.org/jira/browse/KAFKA-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751267#comment-17751267
]
Matthias J. Sax commented on KAFKA-15259:
-
I did sync up with [~cegerton] who wo
Matthias J. Sax created KAFKA-15309:
---
Summary: Add custom error handler to Producer
Key: KAFKA-15309
URL: https://issues.apache.org/jira/browse/KAFKA-15309
Project: Kafka
Issue Type: New Fe
showuon merged PR #14133:
URL: https://github.com/apache/kafka/pull/14133
--
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.
showuon commented on PR #14133:
URL: https://github.com/apache/kafka/pull/14133#issuecomment-1666390423
Failed tests are unrelated:
```
Build / JDK 8 and Scala 2.12 /
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehindR
showuon commented on PR #14151:
URL: https://github.com/apache/kafka/pull/14151#issuecomment-1666390279
> Yeah, okay, this pull request makes sense to me. To summarise, you are
saying that configurations starting with `remote.log.metadata` need to be
passed to implementations of the RemoteL
[
https://issues.apache.org/jira/browse/KAFKA-15259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751263#comment-17751263
]
Matthias J. Sax commented on KAFKA-15259:
-
Thanks for digging into it – that's a
mjsax merged PR #14105:
URL: https://github.com/apache/kafka/pull/14105
--
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
[
https://issues.apache.org/jira/browse/KAFKA-15202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-15202:
---
Assignee: Greg Harris
> MM2 OffsetSyncStore clears too many syncs when sync spacing is vari
gharris1727 opened a new pull request, #14156:
URL: https://github.com/apache/kafka/pull/14156
The new OffsetSyncStore historical translation cache clears more syncs than
necessary when the gap between syncs is variable. This is a problem with the
replacement promotion logic, which only cov
[
https://issues.apache.org/jira/browse/KAFKA-15308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15308:
Affects Version/s: (was: 3.4.0)
(was: 3.5.0)
> Wipe Stores
Colt McNealy created KAFKA-15308:
Summary: Wipe Stores upon OffsetOutOfRangeException in ALOS
Key: KAFKA-15308
URL: https://issues.apache.org/jira/browse/KAFKA-15308
Project: Kafka
Issue Type
Matthias J. Sax created KAFKA-15307:
---
Summary: Kafka Streams configuration docs outdate
Key: KAFKA-15307
URL: https://issues.apache.org/jira/browse/KAFKA-15307
Project: Kafka
Issue Type: Ta
mehbey commented on PR #14135:
URL: https://github.com/apache/kafka/pull/14135#issuecomment-1666331731
Updated PR to address comments
--
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
mehbey commented on code in PR #14135:
URL: https://github.com/apache/kafka/pull/14135#discussion_r1284932829
##
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala:
##
@@ -642,7 +642,7 @@ class DynamicBrokerReconfigurationTest extends
QuorumTest
mjsax commented on code in PR #14150:
URL: https://github.com/apache/kafka/pull/14150#discussion_r1284932353
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -890,6 +914,22 @@ public class StreamsConfig extends AbstractConfig {
in(
mjsax commented on PR #14155:
URL: https://github.com/apache/kafka/pull/14155#issuecomment-1666311777
`kafka-site.git` PR: https://github.com/apache/kafka-site/pull/536
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
[
https://issues.apache.org/jira/browse/KAFKA-15267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751241#comment-17751241
]
Satish Duggana commented on KAFKA-15267:
Option 4.1 is the option suggested in
lihaosky commented on code in PR #14139:
URL: https://github.com/apache/kafka/pull/14139#discussion_r1284914061
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StickyTaskAssignor.java:
##
@@ -57,6 +57,7 @@ public StickyTaskAssignor() {
publi
lihaosky commented on code in PR #14150:
URL: https://github.com/apache/kafka/pull/14150#discussion_r1284910264
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java:
##
@@ -267,25 +267,46 @@ public static class AssignmentCon
[
https://issues.apache.org/jira/browse/KAFKA-15302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751236#comment-17751236
]
Matthias J. Sax commented on KAFKA-15302:
-
Thanks for reporting this issue. – Wh
lihaosky commented on code in PR #14139:
URL: https://github.com/apache/kafka/pull/14139#discussion_r1284910181
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java:
##
@@ -43,21 +43,27 @@
public class HighAvailabi
AndrewJSchofield commented on code in PR #14111:
URL: https://github.com/apache/kafka/pull/14111#discussion_r1284873983
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -701,7 +713,9 @@ private long partitionReady(Cluster cluster
mjsax commented on code in PR #14139:
URL: https://github.com/apache/kafka/pull/14139#discussion_r1284866806
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java:
##
@@ -43,21 +43,27 @@
public class HighAvailabilit
mjsax commented on code in PR #14150:
URL: https://github.com/apache/kafka/pull/14150#discussion_r1284793025
##
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##
@@ -755,6 +756,29 @@ public class StreamsConfig extends AbstractConfig {
public static final
[
https://issues.apache.org/jira/browse/KAFKA-15306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lianet Magrans updated KAFKA-15306:
---
Description: Integrate refreshCommittedOffsets logic, currently performed
by the coordinator
Lianet Magrans created KAFKA-15306:
--
Summary: Integrate committed offsets logic when updating fetching
positions
Key: KAFKA-15306
URL: https://issues.apache.org/jira/browse/KAFKA-15306
Project: Kafka
ableegoldman commented on PR #14149:
URL: https://github.com/apache/kafka/pull/14149#issuecomment-1666170754
Test failures are unrelated
Super small fix, would like to get it into 3.6 though
ping also @vvcephei @showuon @wcarlson5 for a review
--
This is an automated message
[
https://issues.apache.org/jira/browse/KAFKA-15090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751214#comment-17751214
]
Chris Egerton commented on KAFKA-15090:
---
This is a tricky one. First off, although
[
https://issues.apache.org/jira/browse/KAFKA-15303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751212#comment-17751212
]
Matthias J. Sax commented on KAFKA-15303:
-
Thanks for filing this ticket.
Kafka
[
https://issues.apache.org/jira/browse/KAFKA-15303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15303:
Issue Type: Improvement (was: Bug)
> Foreign key joins no longer triggered by events on t
[
https://issues.apache.org/jira/browse/KAFKA-15303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15303:
Priority: Major (was: Critical)
> Foreign key joins no longer triggered by events on the
gharris1727 commented on PR #14092:
URL: https://github.com/apache/kafka/pull/14092#issuecomment-1666104751
@fvaleri That does appear to work, because [server-common is not being
excluded from
tools-dependant-libs](https://github.com/apache/kafka/blob/b3db905b27ff4133f4018ac922c9ce2beb2d608
[
https://issues.apache.org/jira/browse/KAFKA-15090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-15090:
--
Description:
Before [https://github.com/apache/kafka/pull/9669], in distributed mode, the
{{S
Philip Nee created KAFKA-15305:
--
Summary: The background thread should try to process the remaining
task until the shutdown timer is expired
Key: KAFKA-15305
URL: https://issues.apache.org/jira/browse/KAFKA-15305
[
https://issues.apache.org/jira/browse/KAFKA-15020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15020:
--
Component/s: unit tests
> integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRange
[
https://issues.apache.org/jira/browse/KAFKA-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15101:
--
Labels: flaky-test (was: )
> Improve testRackAwareRangeAssignor test
> --
[
https://issues.apache.org/jira/browse/KAFKA-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15101:
--
Component/s: unit tests
> Improve testRackAwareRangeAssignor test
> --
[
https://issues.apache.org/jira/browse/KAFKA-15101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751187#comment-17751187
]
Kirk True commented on KAFKA-15101:
---
Looks like a duplicate of KAFKA-15020.
> Improve
Philip Nee created KAFKA-15304:
--
Summary: CompletableApplicationEvents aren't being completed when
the consumer is closing
Key: KAFKA-15304
URL: https://issues.apache.org/jira/browse/KAFKA-15304
Project:
ruslankrivoshein commented on PR #13562:
URL: https://github.com/apache/kafka/pull/13562#issuecomment-1665982738
@fvaleri I summon thee. Please, take one more look
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
UR
lianetm commented on code in PR #14123:
URL: https://github.com/apache/kafka/pull/14123#discussion_r1284689796
##
core/src/test/scala/integration/kafka/api/BaseAsyncConsumerTest.scala:
##
@@ -35,8 +39,12 @@ class BaseAsyncConsumerTest extends AbstractConsumerTest {
consumer
[
https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14682:
--
Description:
We've started using [strict
stubbing|https://javadoc.io/static/org.mockito/mocki
[
https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751178#comment-17751178
]
Chris Egerton commented on KAFKA-14682:
---
I've taken a stab at an upstream Mockito
[
https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-14682:
-
Assignee: Chris Egerton (was: Christo Lolov)
> Unused stubbings are not reported by Mo
[
https://issues.apache.org/jira/browse/KAFKA-15298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751172#comment-17751172
]
Christo Lolov commented on KAFKA-15298:
---
Heya [~ckamal]! Thanks for pointing me to
philipnee opened a new pull request, #14154:
URL: https://github.com/apache/kafka/pull/14154
There's a lot of random build failure, and we aren't sure why. Starting a
fresh build to see if these build failures persist.
--
This is an automated message from the Apache Git Service.
To respo
bachmanity1 commented on PR #14153:
URL: https://github.com/apache/kafka/pull/14153#issuecomment-1665858277
@C0urante @mjsax @cadonna could you please review this?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
bachmanity1 opened a new pull request, #14153:
URL: https://github.com/apache/kafka/pull/14153
Replaced Easymock & Powermock with Mockito in KafkaBasedLogTest.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverag
[
https://issues.apache.org/jira/browse/KAFKA-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746622#comment-17746622
]
Federico Valeri edited comment on KAFKA-15239 at 8/4/23 3:58 PM:
-
fvaleri commented on PR #14092:
URL: https://github.com/apache/kafka/pull/14092#issuecomment-1665804677
@gharris1727 I tried various things, as I'm also learning how this works.
The best solution I found is to move the ThroughputThrottler class from
clients to server-common, adding t
philipnee commented on PR #14118:
URL: https://github.com/apache/kafka/pull/14118#issuecomment-1665733961
I've been seeing stream test failures in the recent commits too!
This PR needs to be rebased against this PR:
https://github.com/apache/kafka/pull/14123 to resolve some of the fai
[
https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14682:
--
Description:
We've started using [strict
stubbing|https://javadoc.io/static/org.mockito/mocki
[
https://issues.apache.org/jira/browse/KAFKA-14682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751125#comment-17751125
]
Chris Egerton commented on KAFKA-14682:
---
[~christo_lolov] were you still planning
satishd merged PR #13984:
URL: https://github.com/apache/kafka/pull/13984
--
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.
satishd commented on PR #13984:
URL: https://github.com/apache/kafka/pull/13984#issuecomment-1665559532
Right, there are a few unrelated test failures, merging it to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
[
https://issues.apache.org/jira/browse/KAFKA-15303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Charles-Eddy updated KAFKA-15303:
-
Attachment: image (1).png
> Foreign key joins no longer triggered by events on the right side of
[
https://issues.apache.org/jira/browse/KAFKA-15267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751099#comment-17751099
]
Christo Lolov commented on KAFKA-15267:
---
Okay, I will send out an email later toda
ivanyu commented on PR #13984:
URL: https://github.com/apache/kafka/pull/13984#issuecomment-1665493163
Thank you @satishd
Seems the failures aren't related
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
[
https://issues.apache.org/jira/browse/KAFKA-15267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751095#comment-17751095
]
Luke Chen commented on KAFKA-15267:
---
(1) and (3) are good to me. The only concern is w
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1284280124
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -667,11 +675,323 @@ public void run() {
}
}
+public void handleLogSt
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1284278935
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -2207,7 +2267,7 @@ case class RetentionSizeBreach(log: UnifiedLog) extends
SegmentDeletionReason {
var si
[
https://issues.apache.org/jira/browse/KAFKA-15195?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751078#comment-17751078
]
Christo Lolov commented on KAFKA-15195:
---
Acknowledged, I will circle-back on this
[
https://issues.apache.org/jira/browse/KAFKA-15267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751077#comment-17751077
]
Christo Lolov commented on KAFKA-15267:
---
Heya [~showuon]. Okay, I propose we do th
[
https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751076#comment-17751076
]
Christo Lolov edited comment on KAFKA-14038 at 8/4/23 10:37 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov reassigned KAFKA-14038:
-
Assignee: Christo Lolov (was: Divij Vaidya)
> Optimize calculation of size for log in
[
https://issues.apache.org/jira/browse/KAFKA-14038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751076#comment-17751076
]
Christo Lolov commented on KAFKA-14038:
---
The remaining part of this ticket is bloc
fvaleri commented on PR #14092:
URL: https://github.com/apache/kafka/pull/14092#issuecomment-1665393332
> So for example, if the node.version is 1.0.0, this condition will be true,
and the script will add DEV jars to CLASSPATH. kafka-run-class.sh then finds
the 1.0.0 jars and adds them to C
[
https://issues.apache.org/jira/browse/KAFKA-15303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Charles-Eddy updated KAFKA-15303:
-
Description:
Hello everyone, I am currently working on a project that uses Kafka Streams
(versi
hudeqi commented on PR #13929:
URL: https://github.com/apache/kafka/pull/13929#issuecomment-1665378793
> I still need to get 3.5.1 out and focus on KIP-405 PRs (targeting 3.6
release) before I get some more time @hudeqi!
Hi, do you have time to review this PR now? I want to combine al
Charles-Eddy created KAFKA-15303:
Summary: Foreign key joins no longer triggered by events on the
right side of the join after deployment with a new compatible Avro schema
Key: KAFKA-15303
URL: https://issues.apac
yashmayya commented on PR #14152:
URL: https://github.com/apache/kafka/pull/14152#issuecomment-1665377020
@cadonna @mjsax would you be able to take a look at this whenever you get a
chance?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
yashmayya commented on code in PR #14152:
URL: https://github.com/apache/kafka/pull/14152#discussion_r1284245654
##
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java:
##
@@ -164,17 +160,6 @@ public void shouldThrowNullPointerIfInnerIsNull
yashmayya commented on code in PR #14152:
URL: https://github.com/apache/kafka/pull/14152#discussion_r1284245654
##
streams/src/test/java/org/apache/kafka/streams/state/internals/WindowStoreBuilderTest.java:
##
@@ -164,17 +160,6 @@ public void shouldThrowNullPointerIfInnerIsNull
satishd commented on code in PR #13561:
URL: https://github.com/apache/kafka/pull/13561#discussion_r1284241897
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -152,16 +152,42 @@ class UnifiedLog(@volatile var logStartOffset: Long,
locally {
initializePartitionMe
yashmayya opened a new pull request, #14152:
URL: https://github.com/apache/kafka/pull/14152
- Part of the larger effort to replace the usage of `EasyMock` and
`PowerMock` with `Mockito` across the project that has been underway for the
last few years (see https://issues.apache.org/jira/bro
showuon opened a new pull request, #14151:
URL: https://github.com/apache/kafka/pull/14151
When configuring RLMM, the configs passed into `configure` method is the
`RemoteLogManagerConfig`. But in `RemoteLogManagerConfig`, there's no configs
related to `remote.log.metadata.*`, ex:
`remote.
satishd commented on PR #13984:
URL: https://github.com/apache/kafka/pull/13984#issuecomment-1665334207
Will merge if the Jenkins jobs do not fail with any related tests.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
[
https://issues.apache.org/jira/browse/KAFKA-15295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash reassigned KAFKA-15295:
Assignee: Luke Chen (was: Kamal Chandraprakash)
> Add config validation
[
https://issues.apache.org/jira/browse/KAFKA-15295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751054#comment-17751054
]
Kamal Chandraprakash commented on KAFKA-15295:
--
[~showuon]
I'm not workin
[
https://issues.apache.org/jira/browse/KAFKA-14598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashwin Pankaj resolved KAFKA-14598.
---
Resolution: Fixed
Did not observe this recently
> Fix flaky ConnectRestApiTest
> --
[
https://issues.apache.org/jira/browse/KAFKA-14598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751051#comment-17751051
]
Ashwin Pankaj commented on KAFKA-14598:
---
Did not see this occuring recently - clos
[
https://issues.apache.org/jira/browse/KAFKA-15083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751036#comment-17751036
]
Luke Chen commented on KAFKA-15083:
---
[~satish.duggana] , sorry that I didn't get the p
[
https://issues.apache.org/jira/browse/KAFKA-15267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751033#comment-17751033
]
Luke Chen commented on KAFKA-15267:
---
Do we have any update on this issue? I think this
satishd commented on code in PR #13984:
URL: https://github.com/apache/kafka/pull/13984#discussion_r1284146317
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -623,10 +632,30 @@ private void copyLogSegment(UnifiedLog log, LogSegment
segment, long nextSegment
[
https://issues.apache.org/jira/browse/KAFKA-15295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17751031#comment-17751031
]
Luke Chen commented on KAFKA-15295:
---
[~ckamal] , are you still working on this? If you
ivanyu commented on code in PR #13984:
URL: https://github.com/apache/kafka/pull/13984#discussion_r1284145024
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java:
##
@@ -66,6 +68,11 @@ public class RemoteLogSegmentMetadata extend
showuon commented on code in PR #13984:
URL: https://github.com/apache/kafka/pull/13984#discussion_r1284105567
##
storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java:
##
@@ -81,6 +81,13 @@ public final class RemoteLogManagerConfig {
cadonna merged PR #14145:
URL: https://github.com/apache/kafka/pull/14145
--
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.
cadonna commented on PR #14145:
URL: https://github.com/apache/kafka/pull/14145#issuecomment-1665114431
Build failures are unrelated:
```
Build / JDK 17 and Scala 2.13 /
integration.kafka.server.FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor()
Build / JDK 11 and
showuon commented on code in PR #14127:
URL: https://github.com/apache/kafka/pull/14127#discussion_r1284009383
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java:
##
@@ -64,302 +65,387 @@
class ConsumerTask implements Runnable, Closea
98 matches
Mail list logo
