[
https://issues.apache.org/jira/browse/KAFKA-16615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16615.
-
Fix Version/s: 3.8.0
Reviewer: David Jacot
Assignee: Dongnuo Lyu
Resolut
[
https://issues.apache.org/jira/browse/KAFKA-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844163#comment-17844163
]
PoAn Yang commented on KAFKA-16677:
---
Hi [~chia7712], I'm interested in this feature. I
Chia-Ping Tsai created KAFKA-16679:
--
Summary: Merge `DeleteRecordsCommandUnitTest` into
`DeleteRecordsCommandTest`, `FeatureCommandUnitTest` into
Key: KAFKA-16679
URL: https://issues.apache.org/jira/browse/KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16677:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Replace ClusterType#ALL and ClusterType#
lucasbru commented on code in PR #15870:
URL: https://github.com/apache/kafka/pull/15870#discussion_r1591960681
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -602,6 +608,47 @@ private void removeUnusedTaskFromStateUpdater(final Tas
lucasbru commented on PR #15874:
URL: https://github.com/apache/kafka/pull/15874#issuecomment-2097704867
@mjsax It does change, because we need to keep a list of tests (with
parameters) that do not work with ARM. The `from_version` parameter does not
change, because only old versions are af
Chia-Ping Tsai created KAFKA-16680:
--
Summary: Make ClusterTestExtensions support SASL
Key: KAFKA-16680
URL: https://issues.apache.org/jira/browse/KAFKA-16680
Project: Kafka
Issue Type: New F
[
https://issues.apache.org/jira/browse/KAFKA-16589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-16589:
---
Parent: KAFKA-16680
Issue Type: Sub-task (was: Improvement)
> Consider removing `Cl
lucasbru merged PR #15856:
URL: https://github.com/apache/kafka/pull/15856
--
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
Chia-Ping Tsai created KAFKA-16681:
--
Summary: Rewrite MiniKDC by Java
Key: KAFKA-16681
URL: https://issues.apache.org/jira/browse/KAFKA-16681
Project: Kafka
Issue Type: Sub-task
Chia-Ping Tsai created KAFKA-16682:
--
Summary: Rewrite JassTestUtils by Java
Key: KAFKA-16682
URL: https://issues.apache.org/jira/browse/KAFKA-16682
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-16680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-16680:
---
Description:
This is a umbrella issue.
In order to migrate more tests to new test infra, we
Chia-Ping Tsai created KAFKA-16683:
--
Summary: Extract security-related helpers from scala.TestUtils to
java class
Key: KAFKA-16683
URL: https://issues.apache.org/jira/browse/KAFKA-16683
Project: Kafk
AndrewJSchofield opened a new pull request, #15878:
URL: https://github.com/apache/kafka/pull/15878
KIP-714 and KIP-1000 introduced 3 new RPCs. These new RPCs were not added to
docs/security.html to document the authorization checks required to perform the
requests.
While I was addin
sidyag commented on code in PR #15837:
URL: https://github.com/apache/kafka/pull/15837#discussion_r1592106849
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -2822,6 +2822,31 @@ class KafkaApisTest extends Logging {
() => kafkaApis.handleWriteTxnMarker
sidyag commented on code in PR #15837:
URL: https://github.com/apache/kafka/pull/15837#discussion_r1592106849
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -2822,6 +2822,31 @@ class KafkaApisTest extends Logging {
() => kafkaApis.handleWriteTxnMarker
[
https://issues.apache.org/jira/browse/KAFKA-16679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844222#comment-17844222
]
Cheng-Kai, Zhang commented on KAFKA-16679:
--
Hi [~chia7712] , could I work on th
clolov commented on code in PR #15673:
URL: https://github.com/apache/kafka/pull/15673#discussion_r1592114443
##
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala:
##
@@ -219,7 +219,7 @@ class ListOffsetsRequestTest extends BaseRequestTest {
TestUtils.gener
clolov commented on code in PR #15673:
URL: https://github.com/apache/kafka/pull/15673#discussion_r1592116050
##
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java:
##
@@ -70,7 +70,7 @@ else if (isolationLevel == IsolationLevel.READ_COMMITTED)
kamalcph commented on PR #15825:
URL: https://github.com/apache/kafka/pull/15825#issuecomment-2097869168
@junrao @satishd @chia7712 @showuon
Updated the test plan in the summary. Verified that the patch fixes the
issue by running the trunk and patched build. With the fix, the high-wa
[
https://issues.apache.org/jira/browse/KAFKA-16679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16679:
--
Assignee: Cheng-Kai, Zhang (was: Chia-Ping Tsai)
> Merge `DeleteRecordsCommandUnitTe
clolov commented on PR #15673:
URL: https://github.com/apache/kafka/pull/15673#issuecomment-2097975706
Heya @junrao! Let me know your thoughts on my responses. I have futher
updated the below + rebased. I am waiting on the tests to finish running and if
they uncover something I will aim to
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592246946
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -410,6 +448,430 @@ public void testOptionEntityTypeNames() {
doTestOptionEntityTypeNames(f
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592249836
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -418,4 +880,77 @@ public static String[] toArray(String... first) {
public static String[] toA
lucasbru commented on code in PR #15871:
URL: https://github.com/apache/kafka/pull/15871#discussion_r1592261128
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -623,6 +623,21 @@ private void addToTasksToClose(final Map> futures,
Rev
[
https://issues.apache.org/jira/browse/KAFKA-12385?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844248#comment-17844248
]
Chia-Ping Tsai commented on KAFKA-12385:
It seems to me `FetchResponse#responseD
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592249836
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -418,4 +880,77 @@ public static String[] toArray(String... first) {
public static String[] toA
Chia-Ping Tsai created KAFKA-16684:
--
Summary: FetchResponse#responseData could return incorrect data
Key: KAFKA-16684
URL: https://issues.apache.org/jira/browse/KAFKA-16684
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-16684?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844251#comment-17844251
]
Chia-Ping Tsai commented on KAFKA-16684:
After
[https://github.com/apache/kafka
cadonna commented on code in PR #15871:
URL: https://github.com/apache/kafka/pull/15871#discussion_r1592297149
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java:
##
@@ -623,6 +623,21 @@ private void addToTasksToClose(final Map> futures,
Revi
showuon commented on code in PR #15690:
URL: https://github.com/apache/kafka/pull/15690#discussion_r1592297330
##
storage/src/test/java/org/apache/kafka/tiered/storage/utils/TieredStorageTestUtils.java:
##
@@ -55,7 +57,7 @@ public class TieredStorageTestUtils {
// Log cle
nizhikov commented on code in PR #15873:
URL: https://github.com/apache/kafka/pull/15873#discussion_r1592313103
##
core/src/test/java/kafka/admin/ConfigCommandUnitTest.java:
##
@@ -410,6 +448,430 @@ public void testOptionEntityTypeNames() {
doTestOptionEntityTypeNames(f
frankvicky opened a new pull request, #15879:
URL: https://github.com/apache/kafka/pull/15879
Remove variable "unimplementedquorum" from EndToEndAuthorizationTest.scala
and SaslEndToEndAuthorizationTest.scala
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI
gongxuanzhang commented on PR #15812:
URL: https://github.com/apache/kafka/pull/15812#issuecomment-2098224856
> Hi @gongxuanzhang and thank you for the contribution!
>
> This is actually an issue in a lot of places, I checked with this
checkstyle.xml rule:
>
> ```
>
[
https://issues.apache.org/jira/browse/KAFKA-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844261#comment-17844261
]
TengYao Chi commented on KAFKA-16682:
-
I am able to handle this issue.
> Rewrite Ja
[
https://issues.apache.org/jira/browse/KAFKA-16682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16682:
--
Assignee: TengYao Chi (was: Chia-Ping Tsai)
> Rewrite JassTestUtils by Java
> --
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r1592386867
##
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -244,21 +248,21 @@ public void doJoinFromLeftThenDel
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r1592386867
##
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -244,21 +248,21 @@ public void doJoinFromLeftThenDel
AyoubOm commented on code in PR #15607:
URL: https://github.com/apache/kafka/pull/15607#discussion_r1592389047
##
streams/src/test/java/org/apache/kafka/streams/integration/KTableKTableForeignKeyJoinIntegrationTest.java:
##
@@ -244,21 +248,21 @@ public void doJoinFromLeftThenDel
cadonna merged PR #15870:
URL: https://github.com/apache/kafka/pull/15870
--
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.
Jorge Esteban Quilcate Otoya created KAFKA-16685:
Summary: RSM Task warn logs do not include parent exception trace
Key: KAFKA-16685
URL: https://issues.apache.org/jira/browse/KAFKA-16685
[
https://issues.apache.org/jira/browse/KAFKA-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-16685:
-
Description:
When RLMTask warning exceptions happen and are logg
[
https://issues.apache.org/jira/browse/KAFKA-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-16685:
-
Summary: RLMTask warn logs do not include parent exception trace
[
https://issues.apache.org/jira/browse/KAFKA-16685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jorge Esteban Quilcate Otoya updated KAFKA-16685:
-
Summary: RLMTask warning logs do not include parent exception tra
jeqo opened a new pull request, #15880:
URL: https://github.com/apache/kafka/pull/15880
[KAFKA-16685]
--
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-
frankvicky opened a new pull request, #15881:
URL: https://github.com/apache/kafka/pull/15881
Check all uses of `TestUtils#resource` and replace with `scala.util.Using`
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentati
cadonna opened a new pull request, #15882:
URL: https://github.com/apache/kafka/pull/15882
Uses the new remove operation of the state updater that returns
a future to handle task assignment.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementa
dajac merged PR #15835:
URL: https://github.com/apache/kafka/pull/15835
--
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-16307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-16307.
-
Fix Version/s: 3.8.0
Reviewer: David Jacot
Resolution: Fixed
> fix EventAccumula
chiacyu commented on code in PR #15863:
URL: https://github.com/apache/kafka/pull/15863#discussion_r1592509827
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -182,6 +183,27 @@ class LogCleaner(initialConfig: CleanerConfig,
cleanerManager.removeMetrics()
Review Co
chiacyu commented on code in PR #15863:
URL: https://github.com/apache/kafka/pull/15863#discussion_r1592516715
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -159,6 +159,7 @@ class LogCleaner(initialConfig: CleanerConfig,
cleaners += cleaner
cleaner.start
chia7712 commented on code in PR #15863:
URL: https://github.com/apache/kafka/pull/15863#discussion_r1592508554
##
core/src/main/scala/kafka/log/LogCleaner.scala:
##
@@ -101,6 +101,7 @@ class LogCleaner(initialConfig: CleanerConfig,
time: Time = Time.SYSTEM) ex
dajac opened a new pull request, #15883:
URL: https://github.com/apache/kafka/pull/15883
This PR is still WIP. I am still playing with an alternative approach.
Trunk:
```
Benchmark (assignmentType)
(assignorType) (isRackAware) (memberCoun
[
https://issues.apache.org/jira/browse/KAFKA-16645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844334#comment-17844334
]
Igor Soarez commented on KAFKA-16645:
-
The vulnerability report flags {{libexpat}} v
KevinZTW opened a new pull request, #15884:
URL: https://github.com/apache/kafka/pull/15884
Merge the unit test functions down to the class of integration test to avoid
two test class under the same file
### Committer Checklist (excluded from commit message)
- [ ] Verify design
chia7712 commented on code in PR #15868:
URL: https://github.com/apache/kafka/pull/15868#discussion_r1592649000
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java:
##
@@ -115,11 +112,11 @@ public void ensureInternalEndpoin
FrankYang0529 commented on code in PR #15872:
URL: https://github.com/apache/kafka/pull/15872#discussion_r1592664550
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/DeleteOffsetsConsumerGroupCommandIntegrationTest.java:
##
@@ -88,7 +113,7 @@ public void testDeleteOf
C0urante commented on code in PR #14309:
URL: https://github.com/apache/kafka/pull/14309#discussion_r1592678706
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java:
##
@@ -392,6 +399,146 @@ protected Map
validateSourceConnectorConfig(SourceConn
FrankYang0529 commented on PR #15821:
URL: https://github.com/apache/kafka/pull/15821#issuecomment-2098714976
Hi @chia7712, I rebase latest trunk branch, so we have
`ConsumerGroupCommandTestUtils` now. The only remaining part is
`SimpleConsumerGroupExecutor`. This is used by `ListConsumerGr
gharris1727 commented on code in PR #15601:
URL: https://github.com/apache/kafka/pull/15601#discussion_r1591293880
##
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java:
##
@@ -184,20 +146,34 @@ public void process(final Record record) {
C0urante commented on PR #14309:
URL: https://github.com/apache/kafka/pull/14309#issuecomment-2098726331
Thanks @gharris1727. I've reverted the changes to `Utils.java` and verified
locally with tests. Everything else looked okay on the previous CI run, going
to merge.
--
This is an autom
jolshan commented on PR #15837:
URL: https://github.com/apache/kafka/pull/15837#issuecomment-2098727340
Sorry I was out of town (at KSB). I will try to take a look today, but
thanks Luke for approving as well :)
--
This is an automated message from the Apache Git Service.
To respond to t
C0urante merged PR #14309:
URL: https://github.com/apache/kafka/pull/14309
--
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-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844345#comment-17844345
]
PoAn Yang commented on KAFKA-16681:
---
Hi [~chia7712], I'm interested in this. If you ar
[
https://issues.apache.org/jira/browse/KAFKA-13328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13328.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> Connect does not perform preflight validatio
[
https://issues.apache.org/jira/browse/KAFKA-13329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-13329.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> Connect does not perform preflight validatio
[
https://issues.apache.org/jira/browse/KAFKA-16681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-16681:
--
Assignee: PoAn Yang (was: Chia-Ping Tsai)
> Rewrite MiniKDC by Java
> --
FrankYang0529 commented on code in PR #15868:
URL: https://github.com/apache/kafka/pull/15868#discussion_r1592697934
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java:
##
@@ -115,11 +112,11 @@ public void ensureInternalEn
FrankYang0529 commented on code in PR #15868:
URL: https://github.com/apache/kafka/pull/15868#discussion_r1592700292
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SessionedProtocolIntegrationTest.java:
##
@@ -115,11 +112,11 @@ public void ensureInternalEn
cadonna commented on code in PR #15408:
URL: https://github.com/apache/kafka/pull/15408#discussion_r1592700226
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerCallbackTest.scala:
##
@@ -0,0 +1,138 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under o
Gaurav Narula created KAFKA-16686:
-
Summary: Flakey tests in TopicBasedRemoteLogMetadataManagerTest
Key: KAFKA-16686
URL: https://issues.apache.org/jira/browse/KAFKA-16686
Project: Kafka
Issu
raminqaf commented on PR #15601:
URL: https://github.com/apache/kafka/pull/15601#issuecomment-2098817942
@gharris1727 Thanks for the feedback! I reverted all the changes you
requested and reverted a couple of other indentation problems that caused a
diff. I can even go further and revert &
[
https://issues.apache.org/jira/browse/KAFKA-16108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844365#comment-17844365
]
Igor Soarez commented on KAFKA-16108:
-
[~ChrisEgerton] is this still relevant? The p
viktorsomogyi commented on PR #15697:
URL: https://github.com/apache/kafka/pull/15697#issuecomment-2098821932
@soarez at the end I chose the shortcut regarding detecting leaders before
shutdown. The reason is complex as the solution that would be required for this
is complex too.
So on o
[
https://issues.apache.org/jira/browse/KAFKA-16656?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844368#comment-17844368
]
Chris Egerton commented on KAFKA-16656:
---
Hi [~leninjoseph] it should be possible t
johnnychhsu commented on code in PR #15861:
URL: https://github.com/apache/kafka/pull/15861#discussion_r1592759299
##
core/src/test/java/kafka/test/ClusterConfig.java:
##
@@ -153,15 +148,19 @@ public Map>
perBrokerOverrideProperties() {
return perBrokerOverrideProperti
[
https://issues.apache.org/jira/browse/KAFKA-16250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Calvin Liu updated KAFKA-16250:
---
Description:
The current coordinator does not validate the offset commits before persisting
it in t
FTR created KAFKA-16687:
---
Summary: Native memory leak by Unsafe_allocatememory in Kafka
Clients 3.7.0
Key: KAFKA-16687
URL: https://issues.apache.org/jira/browse/KAFKA-16687
Project: Kafka
Issue Typ
gaurav-narula opened a new pull request, #15885:
URL: https://github.com/apache/kafka/pull/15885
Some tests in TopicBasedRemoteLogMetadataManagerTest flake because
`waitUntilConsumerCatchesUp` may break early before consumer manager has caught
up with all the events.
This PR adds an
gaurav-narula commented on PR #15885:
URL: https://github.com/apache/kafka/pull/15885#issuecomment-2098848112
CC: @clolov @satishd
--
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 c
[
https://issues.apache.org/jira/browse/KAFKA-16316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844373#comment-17844373
]
Walker Carlson commented on KAFKA-16316:
KIP-1024 was made for this, but it has
johnnychhsu commented on PR #15861:
URL: https://github.com/apache/kafka/pull/15861#issuecomment-2098850247
@chia7712
> As https://github.com/apache/kafka/pull/15766 gets merged now, could you
please fix the build error?
sure, let me rebase the latest trunk and fix that since
m1a2st commented on PR #15779:
URL: https://github.com/apache/kafka/pull/15779#issuecomment-2098864822
@chia7712 , please take a look for this PR, thank you
--
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
m1a2st commented on PR #15840:
URL: https://github.com/apache/kafka/pull/15840#issuecomment-2098869565
@chia7712 , I have been add zookeeper `--bootstrap-server` tests, please
review, thank you
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844379#comment-17844379
]
Philip Nee commented on KAFKA-16687:
Hey [~fortherightous] - we also observed some (
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844381#comment-17844381
]
FTR commented on KAFKA-16687:
-
That's it, there are some topics with 30 partitions. I have t
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee reassigned KAFKA-16687:
--
Assignee: Philip Nee
> Native memory leak by Unsafe_allocatememory in Kafka Clients 3.7.0
>
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844382#comment-17844382
]
FTR commented on KAFKA-16687:
-
BTW, before that I had also encountered heap leak issue in K
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844387#comment-17844387
]
Philip Nee commented on KAFKA-16687:
But this is native memory leak so I suspect it'
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844390#comment-17844390
]
FTR commented on KAFKA-16687:
-
Surely, let me experiment with 3.6 and then feedback here.
>
soarez commented on PR #15836:
URL: https://github.com/apache/kafka/pull/15836#issuecomment-2098918354
`:core:test` timed out only on JDK 8 and Scala 2.12. Restarted the build
--
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-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844394#comment-17844394
]
FTR commented on KAFKA-16687:
-
I am using stress testing to my Java application.
Observing w
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844394#comment-17844394
]
FTR edited comment on KAFKA-16687 at 5/7/24 5:12 PM:
-
I am using str
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844395#comment-17844395
]
Philip Nee commented on KAFKA-16687:
Your application uses KafkaConsumer only right?
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844397#comment-17844397
]
FTR commented on KAFKA-16687:
-
For Kafka client, I have used KafkaConsumer and AdminClient.
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844400#comment-17844400
]
Philip Nee commented on KAFKA-16687:
thanks for the information this is massively he
gaurav-narula commented on PR #15065:
URL: https://github.com/apache/kafka/pull/15065#issuecomment-2098952056
Bumping this thread for more visibility.
Would be nice if we give this a shot since we still run into builds which
[time
out](https://ci-builds.apache.org/blue/organizations/
C0urante commented on code in PR #6934:
URL: https://github.com/apache/kafka/pull/6934#discussion_r1592838802
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -1144,6 +1144,21 @@ public void putConnectorConfig(final Stri
[
https://issues.apache.org/jira/browse/KAFKA-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844408#comment-17844408
]
FTR commented on KAFKA-16687:
-
Actually, this Kafka client is used for a web application. Ju
C0urante commented on code in PR #6934:
URL: https://github.com/apache/kafka/pull/6934#discussion_r1592847527
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java:
##
@@ -242,6 +242,19 @@ public Response putConnectorConfig(fina
1 - 100 of 184 matches
Mail list logo
