[
https://issues.apache.org/jira/browse/KAFKA-17169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867661#comment-17867661
]
Mason Chen commented on KAFKA-17169:
Hi, I'm interested in this issue, can I pick th
m1a2st commented on PR #16645:
URL: https://github.com/apache/kafka/pull/16645#issuecomment-2242148472
@brandboat, Thanks for your reminder, I will rebased lastest commit.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and us
[
https://issues.apache.org/jira/browse/KAFKA-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867659#comment-17867659
]
Chris Egerton commented on KAFKA-17174:
---
I'm not sure this is the right direction
[
https://issues.apache.org/jira/browse/KAFKA-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867658#comment-17867658
]
Dmitry Werner commented on KAFKA-17174:
---
[~chia7712] Hello, can I take task?
> Mi
Matthias J. Sax created KAFKA-17178:
---
Summary: Update KTable.transformValues to new Processor API
Key: KAFKA-17178
URL: https://issues.apache.org/jira/browse/KAFKA-17178
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17177:
--
Assignee: Chia Chuan Yu (was: Chia-Ping Tsai)
> reviewers.py should grep "authors" t
[
https://issues.apache.org/jira/browse/KAFKA-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867653#comment-17867653
]
Chia Chuan Yu commented on KAFKA-17177:
---
Hi,[~chia7712]
Can I have this one? Tha
[
https://issues.apache.org/jira/browse/KAFKA-17177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-17177:
---
Summary: reviewers.py should grep "authors" to offer more candidates of
reviewers informatio
Chia-Ping Tsai created KAFKA-17177:
--
Summary: reviewers.py should include the "authors"
Key: KAFKA-17177
URL: https://issues.apache.org/jira/browse/KAFKA-17177
Project: Kafka
Issue Type: Imp
[
https://issues.apache.org/jira/browse/KAFKA-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17176:
--
Assignee: Kuan Po Tseng (was: Chia-Ping Tsai)
> Move FileLock to server-common modul
chia7712 commented on code in PR #16646:
URL: https://github.com/apache/kafka/pull/16646#discussion_r1685930254
##
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java:
##
@@ -330,18 +346,15 @@ static ArgumentParser argParser() {
.type(String.class
[
https://issues.apache.org/jira/browse/KAFKA-17176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867648#comment-17867648
]
Kuan Po Tseng commented on KAFKA-17176:
---
gentle ping [~chia7712] , may I take over
[
https://issues.apache.org/jira/browse/KAFKA-17175?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17175:
--
Assignee: TengYao Chi (was: Chia-Ping Tsai)
> Remove interface `BrokerNode` and `Con
Chia-Ping Tsai created KAFKA-17176:
--
Summary: Move FileLock to server-common module
Key: KAFKA-17176
URL: https://issues.apache.org/jira/browse/KAFKA-17176
Project: Kafka
Issue Type: Sub-tas
[
https://issues.apache.org/jira/browse/KAFKA-17175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867647#comment-17867647
]
TengYao Chi commented on KAFKA-17175:
-
Hi [~chia7712]
If you are not start working
Chia-Ping Tsai created KAFKA-17175:
--
Summary: Remove interface `BrokerNode` and `ControllerNode`
Key: KAFKA-17175
URL: https://issues.apache.org/jira/browse/KAFKA-17175
Project: Kafka
Issue
chia7712 merged PR #16610:
URL: https://github.com/apache/kafka/pull/16610
--
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
vamossagar12 commented on PR #16628:
URL: https://github.com/apache/kafka/pull/16628#issuecomment-2241917198
Build got aborted. Closing and reopening the PR to let the build getting
triggered again.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
vamossagar12 closed pull request #16628: KAFKA-16056: Revoking connectors and
tasks upon worker poll timeout expiry to prevent duplicate task assignments
URL: https://github.com/apache/kafka/pull/16628
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
chia7712 commented on code in PR #16599:
URL: https://github.com/apache/kafka/pull/16599#discussion_r1685882826
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java:
##
@@ -95,98 +88,60 @@
import static
org.apache.kafka.clients.cons
[
https://issues.apache.org/jira/browse/KAFKA-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-17174:
---
Description:
Connect module has its `EmbeddedKafkaCluster`, so another alternative is to
re
[
https://issues.apache.org/jira/browse/KAFKA-17174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-17174:
---
Description:
Connect module has its `EmbeddedKafkaCluster`, so another alternative is to
re
Chia-Ping Tsai created KAFKA-17174:
--
Summary: Migrate OffsetsApiIntegrationTest to use
ClusterTestExtensions
Key: KAFKA-17174
URL: https://issues.apache.org/jira/browse/KAFKA-17174
Project: Kafka
loicgreffier commented on PR #16300:
URL: https://github.com/apache/kafka/pull/16300#issuecomment-2241810066
@cadonna This PR contains the handling of processing exceptions in
`StreamTask#punctuate`:
- `StreamsException` are not handled right now. We could include them in the
catch block
C0urante commented on code in PR #16647:
URL: https://github.com/apache/kafka/pull/16647#discussion_r1685806605
##
connect/runtime/src/test/resources/test-plugins/bad-packaging/META-INF/services/org.apache.kafka.connect.storage.Converter:
##
@@ -14,6 +14,7 @@
# limitations und
C0urante commented on code in PR #16647:
URL: https://github.com/apache/kafka/pull/16647#discussion_r1685806524
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginScannerTest.java:
##
@@ -37,13 +36,9 @@
public class PluginScannerTest {
-pr
C0urante commented on code in PR #16647:
URL: https://github.com/apache/kafka/pull/16647#discussion_r1685806406
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorValidationIntegrationTest.java:
##
@@ -520,17 +543,6 @@ public byte[] fromConnectHeader(
C0urante commented on PR #16647:
URL: https://github.com/apache/kafka/pull/16647#issuecomment-2241763358
@gharris1727 I've been working on de-flaking our Connect and MM2 integration
tests lately and realized that this fix would be a nice quality-of-life
improvement to help speed up the proc
C0urante opened a new pull request, #16647:
URL: https://github.com/apache/kafka/pull/16647
[Jira](https://issues.apache.org/jira/browse/KAFKA-16068)
This is based loosely off of the changes in
https://github.com/apache/kafka/pull/15642, but with modifications that address
some of th
[
https://issues.apache.org/jira/browse/KAFKA-12679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17867622#comment-17867622
]
Colt McNealy commented on KAFKA-12679:
--
[~lucasbru] thanks for the comment and sorr
[
https://issues.apache.org/jira/browse/KAFKA-17162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ao Li updated KAFKA-17162:
--
Description:
The `DefaultTaskManagerTest#shouldReturnFromAwaitOnInterruption` will fail with
the following pa
brandboat commented on PR #16645:
URL: https://github.com/apache/kafka/pull/16645#issuecomment-2241707304
gentle ping @m1a2st , you may need to rebase to the latest commit, the test
file ProducerStateManagerTest.scala has been updated by
https://github.com/apache/kafka/commit/94f5a4f63e7a38
brandboat opened a new pull request, #16646:
URL: https://github.com/apache/kafka/pull/16646
related to https://issues.apache.org/jira/browse/KAFKA-16900,
Currently, users need to set --transaction-duration-ms to enable
transactions in kafka-producer-perf-test, which is not straightfo
m1a2st opened a new pull request, #16645:
URL: https://github.com/apache/kafka/pull/16645
Jira: https://issues.apache.org/jira/browse/KAFKA-17149
move ProducerStateManagerTest to storage module and change to Java code
### Committer Checklist (excluded from commit message)
- [ ] V
m1a2st commented on code in PR #16019:
URL: https://github.com/apache/kafka/pull/16019#discussion_r1685761154
##
tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleConsumerTest.java:
##
@@ -239,4 +284,73 @@ public void shouldWorkWithoutTopicOption() throws
IOException {
chia7712 commented on code in PR #16019:
URL: https://github.com/apache/kafka/pull/16019#discussion_r1685752276
##
tools/src/test/java/org/apache/kafka/tools/consumer/ConsoleConsumerTest.java:
##
@@ -239,4 +284,73 @@ public void shouldWorkWithoutTopicOption() throws
IOException
[
https://issues.apache.org/jira/browse/KAFKA-17168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17168.
Fix Version/s: 3.9.0
Resolution: Fixed
> The logPrefix of RemoteLogReader/RemoteSto
chia7712 merged PR #16642:
URL: https://github.com/apache/kafka/pull/16642
--
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
FrankYang0529 commented on code in PR #16387:
URL: https://github.com/apache/kafka/pull/16387#discussion_r1685748324
##
storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java:
##
@@ -0,0 +1,416 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
FrankYang0529 commented on code in PR #16387:
URL: https://github.com/apache/kafka/pull/16387#discussion_r1685748202
##
storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java:
##
@@ -0,0 +1,416 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
wernerdv commented on PR #16500:
URL: https://github.com/apache/kafka/pull/16500#issuecomment-2241619049
@chia7712 all conflicts are resolved.
--
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
wernerdv commented on code in PR #16500:
URL: https://github.com/apache/kafka/pull/16500#discussion_r1685743220
##
core/src/test/java/kafka/admin/AclCommandTest.java:
##
@@ -0,0 +1,729 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor
FrankYang0529 commented on code in PR #16641:
URL: https://github.com/apache/kafka/pull/16641#discussion_r1685741713
##
core/src/test/scala/unit/kafka/log/LogManagerTest.scala:
##
@@ -949,6 +949,7 @@ class LogManagerTest {
appendRecordsToLog(mockTime, logDir1, 0, mockBroker
FrankYang0529 commented on code in PR #16499:
URL: https://github.com/apache/kafka/pull/16499#discussion_r1685740577
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -119,7 +139,27 @@ public Stream
provideTestTemplateInvocationContex
return gene
kamalcph commented on code in PR #16615:
URL: https://github.com/apache/kafka/pull/16615#discussion_r1685730309
##
core/src/main/java/kafka/log/remote/RemoteLogManager.java:
##
@@ -433,10 +433,13 @@ private void cacheTopicPartitionIds(TopicIdPartition
topicIdPartition) {
chia7712 commented on code in PR #16599:
URL: https://github.com/apache/kafka/pull/16599#discussion_r1685723572
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java:
##
@@ -95,98 +88,60 @@
import static
org.apache.kafka.clients.cons
chia7712 commented on code in PR #16387:
URL: https://github.com/apache/kafka/pull/16387#discussion_r1685710155
##
storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java:
##
@@ -0,0 +1,416 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
chia7712 commented on code in PR #16499:
URL: https://github.com/apache/kafka/pull/16499#discussion_r1685709868
##
core/src/test/java/kafka/test/junit/ClusterTestExtensions.java:
##
@@ -119,7 +139,27 @@ public Stream
provideTestTemplateInvocationContex
return generated
chia7712 commented on code in PR #16599:
URL: https://github.com/apache/kafka/pull/16599#discussion_r1685709519
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java:
##
@@ -95,98 +88,60 @@
import static
org.apache.kafka.clients.cons
chia7712 commented on PR #16500:
URL: https://github.com/apache/kafka/pull/16500#issuecomment-2241561688
@wernerdv could you please fix the conflicts? thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
chia7712 commented on PR #16592:
URL: https://github.com/apache/kafka/pull/16592#issuecomment-2241561603
@brandboat Could you please rebase code?
--
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 t
chia7712 commented on code in PR #16627:
URL: https://github.com/apache/kafka/pull/16627#discussion_r1685705213
##
core/src/test/java/kafka/test/ClusterInstance.java:
##
@@ -183,6 +193,67 @@ default Set supportedGroupProtocols() {
//---[wait]--
chia7712 commented on code in PR #16558:
URL: https://github.com/apache/kafka/pull/16558#discussion_r1685704339
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java:
##
@@ -574,7 +574,7 @@ private static Optional
validateRecord(RecordBatch batch,
[
https://issues.apache.org/jira/browse/KAFKA-17082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17082.
Fix Version/s: 3.9.0
Resolution: Fixed
> Replace kafka.utils.LogCaptureAppender wit
chia7712 merged PR #16601:
URL: https://github.com/apache/kafka/pull/16601
--
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
[
https://issues.apache.org/jira/browse/KAFKA-17153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17153.
Fix Version/s: 3.9.0
Resolution: Fixed
> KafkaMetricsGroup#newGauge should accept f
chia7712 merged PR #16618:
URL: https://github.com/apache/kafka/pull/16618
--
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
chia7712 commented on code in PR #16638:
URL: https://github.com/apache/kafka/pull/16638#discussion_r1685701571
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -2965,7 +2976,21 @@ public void testSubscriptionOnInvalidTopic(GroupProtocol
brandboat opened a new pull request, #16644:
URL: https://github.com/apache/kafka/pull/16644
related to https://issues.apache.org/jira/browse/KAFKA-17038,
This is a follow-up after
[KIP-919](https://cwiki.apache.org/confluence/display/KAFKA/KIP-919%3A+Allow+AdminClient+to+Talk+Directly+wi
wernerdv commented on PR #16620:
URL: https://github.com/apache/kafka/pull/16620#issuecomment-2241517600
@chia7712 Hello, can you take a look?
--
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
vamossagar12 commented on PR #16628:
URL: https://github.com/apache/kafka/pull/16628#issuecomment-2241507720
> > Can't seem to run ./gradlew :connect:runtime:spotlessApply locally. Let
me check this and updatez
>
> spotless behavior is jre-version-dependent, you can run with JDK11 and
[
https://issues.apache.org/jira/browse/KAFKA-17144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17144.
Fix Version/s: 3.9.0
Resolution: Fixed
> Retract v6 of ListGroups RPC added in erro
chia7712 merged PR #16635:
URL: https://github.com/apache/kafka/pull/16635
--
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
63 matches
Mail list logo
