[
https://issues.apache.org/jira/browse/KAFKA-16356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830781#comment-17830781
]
Linu Shibu commented on KAFKA-16356:
Yes [~yondy] , I will update this soon, thanks!
> Remove
showuon commented on code in PR #15600:
URL: https://github.com/apache/kafka/pull/15600#discussion_r1538541164
##
README.md:
##
@@ -285,6 +285,16 @@ See [tests/README.md](tests/README.md).
See [vagrant/README.md](vagrant/README.md).
+### Running in Docker ###
+You could
showuon commented on code in PR #15596:
URL: https://github.com/apache/kafka/pull/15596#discussion_r1538537571
##
README.md:
##
@@ -56,7 +56,11 @@ Follow instructions in https://kafka.apache.org/quickstart
### Running a particular unit/integration test with log4j output ###
showuon commented on PR #15505:
URL: https://github.com/apache/kafka/pull/15505#issuecomment-2019263725
Re-running CI build:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-15505/6/
--
This is an automated message from the Apache Git Service.
To respond to the message, please
KevinZTW opened a new pull request, #15600:
URL: https://github.com/apache/kafka/pull/15600
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of
brandboat commented on code in PR #15588:
URL: https://github.com/apache/kafka/pull/15588#discussion_r1538483814
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -67,13 +67,17 @@ public class TopicConfig {
"(which consists of log
brandboat commented on code in PR #15588:
URL: https://github.com/apache/kafka/pull/15588#discussion_r1538478333
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -67,13 +67,17 @@ public class TopicConfig {
"(which consists of log
brandboat commented on code in PR #15588:
URL: https://github.com/apache/kafka/pull/15588#discussion_r1538478333
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -67,13 +67,17 @@ public class TopicConfig {
"(which consists of log
brandboat commented on code in PR #15588:
URL: https://github.com/apache/kafka/pull/15588#discussion_r1538478333
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -67,13 +67,17 @@ public class TopicConfig {
"(which consists of log
showuon commented on code in PR #15463:
URL: https://github.com/apache/kafka/pull/15463#discussion_r1538452997
##
core/src/test/scala/unit/kafka/server/ReplicaManagerTest.scala:
##
@@ -4164,16 +4164,13 @@ class ReplicaManagerTest {
mock(classOf[FetchDataInfo])
[
https://issues.apache.org/jira/browse/KAFKA-16409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-16409.
---
Fix Version/s: 3.8.0
Resolution: Fixed
> kafka-delete-records / DeleteRecordsCommand should
showuon merged PR #15586:
URL: https://github.com/apache/kafka/pull/15586
--
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 #15586:
URL: https://github.com/apache/kafka/pull/15586#issuecomment-2019187474
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
[
https://issues.apache.org/jira/browse/KAFKA-15265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830734#comment-17830734
]
Henry Cai commented on KAFKA-15265:
---
How is the progress of this tiered storage quota work? We are
[
https://issues.apache.org/jira/browse/KAFKA-16240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830733#comment-17830733
]
Zhiyuan Lei commented on KAFKA-16240:
-
```
TimeUnit.MILLISECONDS.sleep(1)
val result1 =
philipnee commented on PR #15576:
URL: https://github.com/apache/kafka/pull/15576#issuecomment-2019090272
@kirktrue @lucasbru - mind taking a second look? For this specific PR I only
modified the tests using console consumer that's why several tests cases were
omitted.
--
This is an
philipnee commented on code in PR #15594:
URL: https://github.com/apache/kafka/pull/15594#discussion_r1538356233
##
tests/kafkatest/services/connect.py:
##
@@ -534,33 +535,40 @@ def received_messages(self):
def start(self):
self.logger.info("Creating connector
jolshan merged PR #15559:
URL: https://github.com/apache/kafka/pull/15559
--
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:
jolshan commented on PR #15559:
URL: https://github.com/apache/kafka/pull/15559#issuecomment-2019067710
[
https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830728#comment-17830728
]
Justine Olshan commented on KAFKA-14089:
I've seen this again as well.
[
https://issues.apache.org/jira/browse/KAFKA-15914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830727#comment-17830727
]
Justine Olshan commented on KAFKA-15914:
I'm seeing this as well.
kirktrue opened a new pull request, #15599:
URL: https://github.com/apache/kafka/pull/15599
WIP
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
gharris1727 commented on code in PR #15389:
URL: https://github.com/apache/kafka/pull/15389#discussion_r1538282799
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -115,64 +115,61 @@ public class StandaloneHerderTest
philipnee commented on PR #15525:
URL: https://github.com/apache/kafka/pull/15525#issuecomment-2018886221
Hey @lucasbru - Thanks for taking the time to review this PR. Let me know
if there's anything to add to the PR.
--
This is an automated message from the Apache Git Service.
To
philipnee commented on code in PR #15525:
URL: https://github.com/apache/kafka/pull/15525#discussion_r1538195311
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java:
##
@@ -423,11 +432,11 @@ private CompletableFuture
lianetm commented on PR #15585:
URL: https://github.com/apache/kafka/pull/15585#issuecomment-2018835239
Hey @Phuc-Hong-Tran , thanks a lot for the PR! I had a first pass and left
some comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
soarez commented on code in PR #15588:
URL: https://github.com/apache/kafka/pull/15588#discussion_r1538177857
##
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java:
##
@@ -67,13 +67,17 @@ public class TopicConfig {
"(which consists of log segments)
lianetm commented on code in PR #15585:
URL: https://github.com/apache/kafka/pull/15585#discussion_r1538180339
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1667,6 +1667,9 @@ private void
lianetm commented on code in PR #15585:
URL: https://github.com/apache/kafka/pull/15585#discussion_r1538173798
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java:
##
@@ -550,6 +550,11 @@ public ConsumerGroupHeartbeatRequestData
[
https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830685#comment-17830685
]
Greg Harris edited comment on KAFKA-16344 at 3/25/24 8:06 PM:
--
Hi
[
https://issues.apache.org/jira/browse/KAFKA-16344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830685#comment-17830685
]
Greg Harris commented on KAFKA-16344:
-
Hi [~janardhanag] Yes, you should consider increasing
[
https://issues.apache.org/jira/browse/KAFKA-16224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna closed KAFKA-16224.
-
> Fix handling of deleted topic when auto-committing before revocation
>
cadonna merged PR #15581:
URL: https://github.com/apache/kafka/pull/15581
--
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:
lianetm commented on code in PR #15585:
URL: https://github.com/apache/kafka/pull/15585#discussion_r1538161659
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -433,7 +433,7 @@ class PlaintextConsumerTest extends BaseConsumerTest {
*/
//
cadonna commented on PR #15581:
URL: https://github.com/apache/kafka/pull/15581#issuecomment-2018802319
Build failures 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
lianetm commented on code in PR #15585:
URL: https://github.com/apache/kafka/pull/15585#discussion_r1538161334
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -374,7 +374,7 @@ class PlaintextConsumerTest extends BaseConsumerTest {
*/
//
lianetm commented on code in PR #15585:
URL: https://github.com/apache/kafka/pull/15585#discussion_r1538158322
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java:
##
@@ -1750,8 +1753,14 @@ private void subscribeInternal(Pattern pattern,
[
https://issues.apache.org/jira/browse/KAFKA-16420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-16420:
Summary: Add thread-safe alternative to utils.Exit (was: Replace
utils.Exit with a thread-safe
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16294:
Description:
The online upgrade is triggered when a consumer group heartbeat request is
received
cmccabe commented on PR #15584:
URL: https://github.com/apache/kafka/pull/15584#issuecomment-2018746846
> I don't think it's a good idea to introduce the new terms mangling &
unmangling when there are already equivalent terms in the codebase –
sanitizing/desanitizing – it makes it
[
https://issues.apache.org/jira/browse/KAFKA-16294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongnuo Lyu updated KAFKA-16294:
Description:
The online upgrade is triggered when a consumer group heartbeat request is
received
ahmedsobeh commented on code in PR #15389:
URL: https://github.com/apache/kafka/pull/15389#discussion_r1538122992
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerderTest.java:
##
@@ -726,21 +683,21 @@ public void testAccessors() throws
cmccabe commented on code in PR #15584:
URL: https://github.com/apache/kafka/pull/15584#discussion_r1538115580
##
core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala:
##
@@ -50,44 +51,54 @@ class ZkConfigMigrationClient(
val adminZkClient = new
cmccabe commented on code in PR #15584:
URL: https://github.com/apache/kafka/pull/15584#discussion_r1538115580
##
core/src/main/scala/kafka/zk/migration/ZkConfigMigrationClient.scala:
##
@@ -50,44 +51,54 @@ class ZkConfigMigrationClient(
val adminZkClient = new
jeffkbkim commented on PR #15446:
URL: https://github.com/apache/kafka/pull/15446#issuecomment-2018694290
thanks @dajac. I have addressed your 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
[
https://issues.apache.org/jira/browse/KAFKA-16200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16200:
-
Assignee: Kirk True (was: Bruno Cadonna)
> Enforce that RequestManager implementations
gharris1727 opened a new pull request, #15598:
URL: https://github.com/apache/kafka/pull/15598
This adds a thread-safe alternative to the current Exit implementation,
which doesn't make use of static mutable fields. This solves a number of
problems:
1. Thread isolation: Two tests
wcarlson5 commented on code in PR #15414:
URL: https://github.com/apache/kafka/pull/15414#discussion_r1538043755
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java:
##
@@ -236,6 +252,91 @@ private List topicPartitionsForStore(final
[
https://issues.apache.org/jira/browse/KAFKA-16160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16160:
--
Priority: Blocker (was: Major)
> AsyncKafkaConsumer is trying to connect to a disconnected node in a
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Priority: Critical (was: Blocker)
> ConsumerNetworkThread is running tight loop
>
[
https://issues.apache.org/jira/browse/KAFKA-15950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-15950.
-
Fix Version/s: 3.8.0
Resolution: Fixed
merged the PR to trunk.
> Serialize broker heartbeat
junrao merged PR #14903:
URL: https://github.com/apache/kafka/pull/14903
--
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:
[
https://issues.apache.org/jira/browse/KAFKA-15250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15250:
--
Priority: Blocker (was: Major)
> ConsumerNetworkThread is running tight loop
>
junrao commented on PR #14903:
URL: https://github.com/apache/kafka/pull/14903#issuecomment-2018530584
@soarez : Thanks for triaging the test failures. Will merge the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/KAFKA-16271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16271:
-
Assignee: Philip Nee
> Update consumer_rolling_upgrade_test.py to support KIP-848’s group
soarez commented on PR #14903:
URL: https://github.com/apache/kafka/pull/14903#issuecomment-2018506864
@junrao all the failed tests are being tracked.
These were already tracked:
* KAFKA-8041
kafka.server.LogDirFailureTest.testIOExceptionDuringCheckpoint(String).quorum=kraft
Igor Soarez created KAFKA-16422:
---
Summary: Flaky test
org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest."testFailingOverIncrementsNewActiveControllerCount(boolean).true"
Key: KAFKA-16422
URL:
[
https://issues.apache.org/jira/browse/KAFKA-14246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True resolved KAFKA-14246.
---
Resolution: Fixed
> Update threading model for Consumer
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830603#comment-17830603
]
Greg Harris commented on KAFKA-16420:
-
I can't find a single ticket for "Remove Zookeeper", but I
Greg Harris created KAFKA-16421:
---
Summary: Refactor CommandDefaultOptions subclasses to throw
exceptions instead of calling exit.
Key: KAFKA-16421
URL: https://issues.apache.org/jira/browse/KAFKA-16421
[
https://issues.apache.org/jira/browse/KAFKA-16349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830590#comment-17830590
]
Greg Harris commented on KAFKA-16349:
-
I added a tactical fix for the Exit class in my PR to resolve
OmniaGM commented on PR #15575:
URL: https://github.com/apache/kafka/pull/15575#issuecomment-2018444788
> Hello @AndrewJSchofield @OmniaGM
>
> Looks like dependency on server tests not required but introduced in this
PR. I have plans to double check this after minor comment in #15569
Greg Harris created KAFKA-16420:
---
Summary: Replace utils.Exit with a thread-safe alternative
Key: KAFKA-16420
URL: https://issues.apache.org/jira/browse/KAFKA-16420
Project: Kafka
Issue Type:
jolshan commented on PR #15559:
URL: https://github.com/apache/kafka/pull/15559#issuecomment-2018411363
Getting a fresh build before merging
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830576#comment-17830576
]
Greg Harris commented on KAFKA-16398:
-
Hi [~srivignesh] Thank you for providing your configuration.
junrao commented on PR #14903:
URL: https://github.com/apache/kafka/pull/14903#issuecomment-2018408733
@soarez : Are the failed tests in the latest run being tracked?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
FrankYang0529 commented on PR #15505:
URL: https://github.com/apache/kafka/pull/15505#issuecomment-2018399116
> @FrankYang0529 , there are some tests failing because of your change.
Please take a look. Thanks.
>
> https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-15505/4
gharris1727 opened a new pull request, #15597:
URL: https://github.com/apache/kafka/pull/15597
Add Utils.castToStringObjectMap and fix unchecked casts in AbstractConfig
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify
[
https://issues.apache.org/jira/browse/KAFKA-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johnny Hsu updated KAFKA-16419:
---
Description:
Currently in the
[
https://issues.apache.org/jira/browse/KAFKA-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johnny Hsu updated KAFKA-16419:
---
Description:
Currently in the
FrankYang0529 commented on PR #15586:
URL: https://github.com/apache/kafka/pull/15586#issuecomment-2018334375
> Failed with the same error again. Please help fix the errors. Thanks.
Sorry, I will double check test result before creating a PR next time. I
have updated the case. Thank
[
https://issues.apache.org/jira/browse/KAFKA-16419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johnny Hsu updated KAFKA-16419:
---
Description:
Currently in the LogValidator.validateMessagesAndAssignOffsetsCompressed, there
are
Johnny Hsu created KAFKA-16419:
--
Summary: Abstract validateMessagesAndAssignOffsetsCompressed of
LogValidator to simply the process
Key: KAFKA-16419
URL: https://issues.apache.org/jira/browse/KAFKA-16419
philipnee commented on code in PR #15525:
URL: https://github.com/apache/kafka/pull/15525#discussion_r1537804695
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImpl.java:
##
@@ -411,8 +411,8 @@ public int memberEpoch() {
public void
[
https://issues.apache.org/jira/browse/KAFKA-16318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17830539#comment-17830539
]
Johnny Hsu commented on KAFKA-16318:
the PR is merged, close this ticket
> Add javadoc to
chia7712 closed pull request #9725: MINOR: optimize EvictableKey/LastUsedKey
compareTo function
URL: https://github.com/apache/kafka/pull/9725
--
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
chia7712 closed pull request #9517: MINOR: add comments to explain why it needs
to add synchronization on…
URL: https://github.com/apache/kafka/pull/9517
--
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
chia7712 closed pull request #8978: KAFKA-10234 The key/value deserializer used
by ConsoleConsumer is not…
URL: https://github.com/apache/kafka/pull/8978
--
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
chia7712 closed pull request #9796: KAFKA-10498 Consumer should do offset/epoch
validation through when …
URL: https://github.com/apache/kafka/pull/9796
--
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
chia7712 closed pull request #9954: MINOR: apply FilterByKeyIterator and
FlattenedIterator to code base
URL: https://github.com/apache/kafka/pull/9954
--
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
chia7712 closed pull request #9798: MINOR: fix the soft link created by
ducktape when running system test…
URL: https://github.com/apache/kafka/pull/9798
--
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
chia7712 closed pull request #9641: MINOR: Convert connect assignment schemas
to use generated protocol
URL: https://github.com/apache/kafka/pull/9641
--
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
chia7712 closed pull request #10269: KAFKA-12410 KafkaAPis ought to group fetch
data before generating fet…
URL: https://github.com/apache/kafka/pull/10269
--
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
chia7712 closed pull request #10283: MINOR: KRPC supports to get true type from
entity type
URL: https://github.com/apache/kafka/pull/10283
--
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
chia7712 closed pull request #10261: MINOR: using INFO level to log 'no
meta.properties' for broker server
URL: https://github.com/apache/kafka/pull/10261
--
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
chia7712 closed pull request #10248: MINOR: main function of o.a.k.c.p.t.Type
does not show all types
URL: https://github.com/apache/kafka/pull/10248
--
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
chia7712 closed pull request #10077: KAFKA-12309 The revocation algorithm
produces uneven distributions
URL: https://github.com/apache/kafka/pull/10077
--
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
chia7712 closed pull request #10577: MINOR: check duplicate advertised
listeners based on resolved host
URL: https://github.com/apache/kafka/pull/10577
--
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
chia7712 closed pull request #11128: MINOR: remove partition-level error from
MetadataResponse#errorCounts
URL: https://github.com/apache/kafka/pull/11128
--
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
chia7712 closed pull request #12528: MINOR: don't record the throttled rate
when there is no throttled par…
URL: https://github.com/apache/kafka/pull/12528
--
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
chia7712 closed pull request #13285: KAFKA-13874 Avoid synchronization in
SocketServer metrics
URL: https://github.com/apache/kafka/pull/13285
--
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
chia7712 closed pull request #13395: MINOR: don't disconnect stale controller
if the network client is res…
URL: https://github.com/apache/kafka/pull/13395
--
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
chia7712 closed pull request #13405: KAFKA-14811 The forwarding requests are
discarded when network client…
URL: https://github.com/apache/kafka/pull/13405
--
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
cadonna commented on PR #15581:
URL: https://github.com/apache/kafka/pull/15581#issuecomment-2018163251
Sorry for that! I do not know why I am so sloppy with this PR. I am going to
fix this now.
--
This is an automated message from the Apache Git Service.
To respond to the message,
KevinZTW commented on code in PR #15596:
URL: https://github.com/apache/kafka/pull/15596#discussion_r1537700914
##
README.md:
##
@@ -56,7 +56,11 @@ Follow instructions in https://kafka.apache.org/quickstart
### Running a particular unit/integration test with log4j output ###
lucasbru merged PR #15535:
URL: https://github.com/apache/kafka/pull/15535
--
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:
lucasbru commented on PR #15535:
URL: https://github.com/apache/kafka/pull/15535#issuecomment-2018145845
Two related flaky tests,
`kafka.api.PlaintextConsumerTest.testExpandingTopicSubscriptions(String,
String)[4]` and
chickenchickenlove commented on code in PR #15573:
URL: https://github.com/apache/kafka/pull/15573#discussion_r1537690828
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java:
##
@@ -119,7 +119,8 @@ public Queue
chickenchickenlove commented on code in PR #15573:
URL: https://github.com/apache/kafka/pull/15573#discussion_r1537690828
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java:
##
@@ -119,7 +119,8 @@ public Queue
johnnychhsu commented on PR #15463:
URL: https://github.com/apache/kafka/pull/15463#issuecomment-2018127603
updated @showuon
it works in my local, thanks for the sharing!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
1 - 100 of 168 matches
Mail list logo
