Ramiz Mehran created KAFKA-16582:
Summary: Feature Request: Introduce max.record.size Configuration
Parameter for Producers
Key: KAFKA-16582
URL: https://issues.apache.org/jira/browse/KAFKA-16582
[
https://issues.apache.org/jira/browse/KAFKA-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838450#comment-17838450
]
Ramiz Mehran commented on KAFKA-10034:
--
"Firstly, this configuration is a cap on the maximum
[ https://issues.apache.org/jira/browse/KAFKA-10034 ]
Ramiz Mehran deleted comment on KAFKA-10034:
--
was (Author: JIRAUSER290918):
"Firstly, this configuration is a cap on the maximum uncompressed record batch
size." should be changed to
[
https://issues.apache.org/jira/browse/KAFKA-10034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838447#comment-17838447
]
Ramiz Mehran commented on KAFKA-10034:
--
"Firstly, this configuration is a cap on the maximum
vamossagar12 commented on PR #15305:
URL: https://github.com/apache/kafka/pull/15305#issuecomment-2062936947
@showuon , just checking did you get a chance to look at the updated test?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-16467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838438#comment-17838438
]
ASF GitHub Bot commented on KAFKA-16467:
showuon merged PR #596:
URL:
showuon commented on PR #15616:
URL: https://github.com/apache/kafka/pull/15616#issuecomment-2062889530
@FrankYang0529 , there is checkstyle error:
`[2024-04-17T14:04:27.072Z] [ant:checkstyle] [ERROR]
showuon commented on code in PR #15616:
URL: https://github.com/apache/kafka/pull/15616#discussion_r1569846240
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegment.java:
##
@@ -801,8 +803,23 @@ private Void deleteTypeIfExists(StorageAction delete, Stri
showuon merged PR #15747:
URL: https://github.com/apache/kafka/pull/15747
--
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:
showuon commented on PR #15747:
URL: https://github.com/apache/kafka/pull/15747#issuecomment-2062884304
Failed tests are unrelated.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific
showuon commented on PR #15748:
URL: https://github.com/apache/kafka/pull/15748#issuecomment-2062882937
Looks like `LogCleanerParameterizedIntegrationTest` failed due to this
change. Please take a look. Thanks.
aaron-ai commented on code in PR #15728:
URL: https://github.com/apache/kafka/pull/15728#discussion_r1569813058
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java:
##
@@ -169,6 +170,7 @@ static Map sourceConsumerConfig(Map props) {
[
https://issues.apache.org/jira/browse/KAFKA-16574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838420#comment-17838420
]
Chia Chuan Yu commented on KAFKA-16574:
---
Hi, [~chia7712]
Can I have this one ? thanks!
> The
TaiJuWu commented on code in PR #15749:
URL: https://github.com/apache/kafka/pull/15749#discussion_r1569739083
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1082,7 +1082,7 @@ private[kafka] class Processor(
// `protected` for test usage
TaiJuWu closed pull request #15749: MINOR: Modify SocketServer#sendResponse
trace msg
URL: https://github.com/apache/kafka/pull/15749
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Description:
The {{consumer_test.py}} system test intermittently fails with the following
error:
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Summary: New consumer fails with stop within allotted timeout in
consumer_test.py system test (was:
jolshan commented on PR #15685:
URL: https://github.com/apache/kafka/pull/15685#issuecomment-2062753494
I noticed I need to do Quorum and Broker features which are basically the
same implementation. Stay tuned.
--
This is an automated message from the Apache Git Service.
To respond to
José Armando García Sancio created KAFKA-16581:
--
Summary: Implement KafkaRaftClient unittest for membership change
Key: KAFKA-16581
URL: https://issues.apache.org/jira/browse/KAFKA-16581
[
https://issues.apache.org/jira/browse/KAFKA-16580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-16580:
---
Description: Update RaftEventSimulationTest to validate
José Armando García Sancio created KAFKA-16580:
--
Summary: Write simulation tests for kraft membership change
Key: KAFKA-16580
URL: https://issues.apache.org/jira/browse/KAFKA-16580
[
https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14094:
---
Fix Version/s: 3.8.0
> KIP-853: KRaft controller membership changes
[
https://issues.apache.org/jira/browse/KAFKA-14094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-14094:
---
Labels: (was: 4.0-blocker)
> KIP-853: KRaft controller membership
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838402#comment-17838402
]
Fu Qiao commented on KAFKA-16557:
-
Created a PR for this if you don't mind:
phooq opened a new pull request, #15750:
URL: https://github.com/apache/kafka/pull/15750
### Description
This PR is for
[KAFKA-16557](https://issues.apache.org/jira/browse/KAFKA-16557). This is to
enhance the debugging and troubleshooting for consumer related issues.
### Test
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16579:
--
Description:
To test the new, asynchronous Kafka {{Consumer}} implementation, we migrated a
slew of
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16579:
--
Description:
To test the new, asynchronous Kafka {{Consumer}} implementation, we migrated a
slew of
[
https://issues.apache.org/jira/browse/KAFKA-16578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16578:
--
Description:
To test the new, asynchronous Kafka {{Consumer}} implementation, we migrated a
slew of
Kirk True created KAFKA-16579:
-
Summary: Revert changes to consumer_rolling_upgrade_test.py for
the new async Consumer
Key: KAFKA-16579
URL: https://issues.apache.org/jira/browse/KAFKA-16579
Project:
[
https://issues.apache.org/jira/browse/KAFKA-16579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16579:
-
Assignee: Philip Nee (was: Kirk True)
> Revert changes to consumer_rolling_upgrade_test.py
Kirk True created KAFKA-16578:
-
Summary: Revert changes to connect_distributed_test.py for the new
async Consumer
Key: KAFKA-16578
URL: https://issues.apache.org/jira/browse/KAFKA-16578
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16576:
--
Labels: flaky-test kip-848-client-support system-tests (was:
kip-848-client-support system-tests)
>
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Labels: flaky-test kip-848-client-support system-tests (was:
kip-848-client-support system-tests)
>
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Description:
The {{consumer_test.py}} system test intermittently fails with the following
error:
[
https://issues.apache.org/jira/browse/KAFKA-16577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16577:
--
Summary: New consumer fails with stop within allotted timeout in
consumer_test.py’s
Kirk True created KAFKA-16577:
-
Summary: New consumer fails with stop timeout in
consumer_test.py’s test_consumer_bounce system test
Key: KAFKA-16577
URL: https://issues.apache.org/jira/browse/KAFKA-16577
[
https://issues.apache.org/jira/browse/KAFKA-16576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16576:
--
Description:
The {{consumer_test.py}} system test intermittently fails with the following
error:
Kirk True created KAFKA-16576:
-
Summary: New consumer fails with assert in consumer_test.py’s
test_consumer_failure system test
Key: KAFKA-16576
URL: https://issues.apache.org/jira/browse/KAFKA-16576
[
https://issues.apache.org/jira/browse/KAFKA-16557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838384#comment-17838384
]
Fu Qiao commented on KAFKA-16557:
-
Hey [~kirktrue] : I am new to Kafka, and would like to start with
splett2 commented on code in PR #15749:
URL: https://github.com/apache/kafka/pull/15749#discussion_r1569578496
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1082,7 +1082,7 @@ private[kafka] class Processor(
// `protected` for test usage
junrao commented on code in PR #15634:
URL: https://github.com/apache/kafka/pull/15634#discussion_r1569562746
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -282,15 +282,15 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Update high watermark
philipnee commented on code in PR #15723:
URL: https://github.com/apache/kafka/pull/15723#discussion_r1569554430
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java:
##
@@ -98,15 +98,15 @@ public NetworkClientDelegate.PollResult
TaiJuWu opened a new pull request, #15749:
URL: https://github.com/apache/kafka/pull/15749
As title.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation
lianetm commented on PR #15698:
URL: https://github.com/apache/kafka/pull/15698#issuecomment-2062253184
Thanks for the comments @kirktrue, all addressed.
Regarding your comment regarding tests
[here](https://github.com/apache/kafka/pull/15698#pullrequestreview-2004676007),
we have
lianetm commented on code in PR #15698:
URL: https://github.com/apache/kafka/pull/15698#discussion_r1569511540
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManagerTest.java:
##
@@ -231,6 +231,35 @@ public void testTimerNotDue() {
jolshan commented on PR #15739:
URL: https://github.com/apache/kafka/pull/15739#issuecomment-2062215298
I ran the test 3 times and it seems to be working ok. I can run a few more
times if we want to confirm the flakiness is gone.
--
This is an automated message from the Apache Git
lianetm commented on code in PR #15698:
URL: https://github.com/apache/kafka/pull/15698#discussion_r1569504137
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -482,6 +482,15 @@ public long nextHeartbeatMs(final long
lianetm commented on code in PR #15698:
URL: https://github.com/apache/kafka/pull/15698#discussion_r1569498394
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -380,7 +380,7 @@ private void onErrorResponse(final
mimaison merged PR #15736:
URL: https://github.com/apache/kafka/pull/15736
--
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:
OmniaGM commented on code in PR #15569:
URL: https://github.com/apache/kafka/pull/15569#discussion_r1569436277
##
core/src/main/scala/kafka/server/ZkAdminManager.scala:
##
@@ -80,10 +80,10 @@ class ZkAdminManager(val config: KafkaConfig,
private val configHelper = new
mimaison commented on PR #15736:
URL: https://github.com/apache/kafka/pull/15736#issuecomment-2062104700
None of the test failures are related, merging to 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
dongnuo123 commented on code in PR #15721:
URL: https://github.com/apache/kafka/pull/15721#discussion_r1569413973
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -777,6 +778,59 @@ public ClassicGroup classicGroup(
birdoplank closed pull request #15743: Fix typo
URL: https://github.com/apache/kafka/pull/15743
--
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:
dongnuo123 commented on code in PR #15721:
URL: https://github.com/apache/kafka/pull/15721#discussion_r1569405350
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -775,6 +777,126 @@ public ClassicGroup classicGroup(
lianetm commented on code in PR #15737:
URL: https://github.com/apache/kafka/pull/15737#discussion_r1569396277
##
tests/kafkatest/services/verifiable_consumer.py:
##
@@ -140,22 +150,32 @@ class
IncrementalAssignmentConsumerEventHandler(ConsumerEventHandler):
def
kamalcph commented on PR #15631:
URL: https://github.com/apache/kafka/pull/15631#issuecomment-2062050733
> @kamalcph : Do you want this PR to be in 3.7 and 3.6? If so, could you
create a separate cherry-pick RP? Thanks.
Opened #15747 and #15748 to backport it to 3.7 and 3.6 branches.
kamalcph opened a new pull request, #15748:
URL: https://github.com/apache/kafka/pull/15748
cherry-picked from: d092787487047178c674bd60a182129a8d997c4a
Co-authored-by: hzh0425 <642256...@qq.com>
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
kamalcph commented on code in PR #15634:
URL: https://github.com/apache/kafka/pull/15634#discussion_r1569356239
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -1223,6 +1223,12 @@ class UnifiedLog(@volatile var logStartOffset: Long,
s"but we only have log
kamalcph commented on code in PR #15634:
URL: https://github.com/apache/kafka/pull/15634#discussion_r1563885907
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -282,15 +282,15 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Update high watermark
kamalcph opened a new pull request, #15747:
URL: https://github.com/apache/kafka/pull/15747
cherry-picked from: d092787487047178c674bd60a182129a8d997c4a
Co-authored-by: hzh0425 <642256...@qq.com>
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
Matthias J. Sax created KAFKA-16575:
---
Summary: Automatically remove KTable aggregation result when group
becomes empty
Key: KAFKA-16575
URL: https://issues.apache.org/jira/browse/KAFKA-16575
kamalcph commented on code in PR #15634:
URL: https://github.com/apache/kafka/pull/15634#discussion_r1569328393
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -282,15 +282,15 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Update high watermark
chia7712 commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1569310965
##
core/src/test/java/kafka/testkit/TestKitNodes.java:
##
@@ -82,6 +82,10 @@ public Builder setNumBrokerNodes(int numBrokerNodes) {
return
Chia-Ping Tsai created KAFKA-16574:
--
Summary: The metrics of LogCleaner disappear after reconfiguration
Key: KAFKA-16574
URL: https://issues.apache.org/jira/browse/KAFKA-16574
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838347#comment-17838347
]
José Armando García Sancio commented on KAFKA-16522:
[~phong260702] thanks for
[
https://issues.apache.org/jira/browse/KAFKA-16405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-16405.
---
Reviewer: Lucas Brutschy
Resolution: Fixed
> Mismatch assignment error when running consumer
kamalcph commented on code in PR #15634:
URL: https://github.com/apache/kafka/pull/15634#discussion_r1563885907
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -282,15 +282,15 @@ class UnifiedLog(@volatile var logStartOffset: Long,
/**
* Update high watermark
chia7712 commented on code in PR #15136:
URL: https://github.com/apache/kafka/pull/15136#discussion_r1569178614
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -1189,50 +1216,63 @@ class LogManager(logDirs: Seq[File],
val sourceLog =
splett2 commented on code in PR #15702:
URL: https://github.com/apache/kafka/pull/15702#discussion_r1569269269
##
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java:
##
@@ -2117,6 +2117,20 @@ ListPartitionReassignmentsResponseData
[
https://issues.apache.org/jira/browse/KAFKA-16003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin McCabe updated KAFKA-16003:
-
Fix Version/s: 3.7.1
> The znode /config/topics is not updated during KRaft migration in
>
junrao commented on code in PR #15673:
URL: https://github.com/apache/kafka/pull/15673#discussion_r1569221453
##
clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsRequest.java:
##
@@ -70,7 +70,7 @@ else if (isolationLevel == IsolationLevel.READ_COMMITTED)
mimaison commented on code in PR #15569:
URL: https://github.com/apache/kafka/pull/15569#discussion_r1569237791
##
core/src/main/scala/kafka/server/ZkAdminManager.scala:
##
@@ -80,10 +80,10 @@ class ZkAdminManager(val config: KafkaConfig,
private val configHelper = new
kirktrue commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1569228945
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -616,6 +620,80 @@ public void
kirktrue commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1569232314
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -616,6 +620,80 @@ public void
kirktrue commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1569231774
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -616,6 +620,80 @@ public void
kirktrue commented on code in PR #15613:
URL: https://github.com/apache/kafka/pull/15613#discussion_r1569226961
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -793,9 +795,9 @@ public void commitAsync(Map offsets, OffsetCo
kirktrue commented on code in PR #15742:
URL: https://github.com/apache/kafka/pull/15742#discussion_r1569217494
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -228,13 +228,16 @@ private void process(final ErrorEvent event) {
cmccabe closed pull request #10589: MINOR: move topic configuration defaults
URL: https://github.com/apache/kafka/pull/10589
--
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
CalvinConfluent commented on code in PR #15702:
URL: https://github.com/apache/kafka/pull/15702#discussion_r1569214320
##
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java:
##
@@ -2117,6 +2117,20 @@ ListPartitionReassignmentsResponseData
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1569214270
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -3003,9 +3008,10 @@ class KafkaApis(val requestChannel: RequestChannel,
}
}
+// Forwarding
cmccabe closed pull request #8115: MINOR: Fix some flaky behavior in
DeleteConsumerGroupsTest and clean up
URL: https://github.com/apache/kafka/pull/8115
--
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
cmccabe closed pull request #12833: KAFKA-14370: Simplify the ImageWriter API
by adding freeze
URL: https://github.com/apache/kafka/pull/12833
--
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
CalvinConfluent commented on code in PR #15702:
URL: https://github.com/apache/kafka/pull/15702#discussion_r1569210550
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -2360,4 +2363,9 @@ void setNewNextWriteOffset(long newNextWriteOffset) {
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1569208039
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
[
https://issues.apache.org/jira/browse/KAFKA-16570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-16570:
---
Description:
When we want to fence a producer using the admin client, we send an
ableegoldman commented on PR #13283:
URL: https://github.com/apache/kafka/pull/13283#issuecomment-2061827689
No pressure! Just wanted to make sure you weren't still waiting on me for
this. Or rather, just wanted to say, if you do want to try and get this in to
3.8 I will make sure to help
C0urante commented on code in PR #15728:
URL: https://github.com/apache/kafka/pull/15728#discussion_r1569197938
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java:
##
@@ -169,6 +170,7 @@ static Map sourceConsumerConfig(Map props) {
kirktrue opened a new pull request, #15746:
URL: https://github.com/apache/kafka/pull/15746
The system test was failing because the `VerifiableConsumer` failed with a
`NullPointerException` during startup. The reason for the NPE was an attempt to
put a `null` as the value of
akhileshchg commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1569190991
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
gaurav-narula commented on code in PR #15745:
URL: https://github.com/apache/kafka/pull/15745#discussion_r1569160539
##
core/src/test/java/kafka/test/junit/RaftClusterInvocationContext.java:
##
@@ -93,7 +93,7 @@ public List getAdditionalExtensions() {
chia7712 commented on PR #15679:
URL: https://github.com/apache/kafka/pull/15679#issuecomment-2061751961
@FrankYang0529 Could you reduce the partition number of offsets topic? It
seems the timeout is caused by that coordinator is waiting for the offset
partition, and our CI could be too
junrao commented on PR #15631:
URL: https://github.com/apache/kafka/pull/15631#issuecomment-2061739168
@kamalcph : Do you want this PR to be in 3.7 and 3.6? If so, could you
create a separate cherry-pick RP? Thanks.
--
This is an automated message from the Apache Git Service.
To respond
junrao merged PR #15631:
URL: https://github.com/apache/kafka/pull/15631
--
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:
junrao commented on PR #15631:
URL: https://github.com/apache/kafka/pull/15631#issuecomment-2061732009
@kamalcph : Thanks for triaging the failed tests. The PR LGTM.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
gaurav-narula commented on code in PR #15136:
URL: https://github.com/apache/kafka/pull/15136#discussion_r1569131419
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -1189,50 +1216,61 @@ class LogManager(logDirs: Seq[File],
val sourceLog =
Ayoub Omari created KAFKA-16573:
---
Summary: Streams does not specify where a Serde is needed
Key: KAFKA-16573
URL: https://issues.apache.org/jira/browse/KAFKA-16573
Project: Kafka
Issue Type:
mimaison commented on code in PR #15569:
URL: https://github.com/apache/kafka/pull/15569#discussion_r1569073857
##
core/src/main/scala/kafka/server/ZkAdminManager.scala:
##
@@ -79,10 +80,10 @@ class ZkAdminManager(val config: KafkaConfig,
private val configHelper = new
FrankYang0529 opened a new pull request, #15745:
URL: https://github.com/apache/kafka/pull/15745
We introduced `disksPerBroker` in `TestKitNodes` from
https://issues.apache.org/jira/browse/KAFKA-16559. We can support to config it
in `ClusterTest`, so it's more convenient for integration
mumrah commented on code in PR #15744:
URL: https://github.com/apache/kafka/pull/15744#discussion_r1569103206
##
core/src/main/scala/kafka/zk/KafkaZkClient.scala:
##
@@ -467,13 +470,33 @@ class KafkaZkClient private[zk] (zooKeeperClient:
ZooKeeperClient, isSecure: Boo
*
dajac commented on code in PR #15721:
URL: https://github.com/apache/kafka/pull/15721#discussion_r1569077848
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -777,6 +778,59 @@ public ClassicGroup classicGroup(
}
1 - 100 of 160 matches
Mail list logo
