chia7712 commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1477362379
> potential exceptions here (although I haven't found it yet, it may be
potential)
Could you share more information with me? The unexpected disk growing is a
critical bug so it wo
hudeqi commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1477368341
> > potential exceptions here (although I haven't found it yet, it may be
potential)
>
> Could you share more information with me? The unexpected disk growing is a
critical bug so i
mukkachaitanya opened a new pull request, #13426:
URL: https://github.com/apache/kafka/pull/13426
…e state
*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.*
[
https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703073#comment-17703073
]
Chaitanya Mukka commented on KAFKA-14814:
-
Hi [~yash.mayya]! If you haven't star
chia7712 commented on PR #13398:
URL: https://github.com/apache/kafka/pull/13398#issuecomment-1477443749
```
[2023-03-20T05:31:14.475Z] BUILD SUCCESSFUL in 1h 44m 21s
[2023-03-20T05:31:14.475Z] 224 actionable tasks: 120 executed, 104 up-to-date
```
the tests pass. will merge i
chia7712 merged PR #13398:
URL: https://github.com/apache/kafka/pull/13398
--
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 PR #13398:
URL: https://github.com/apache/kafka/pull/13398#issuecomment-1477456249
@garyparrot thanks for this contribution
--
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
[
https://issues.apache.org/jira/browse/KAFKA-6891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-6891.
---
Fix Version/s: 3.5.0
Resolution: Fixed
> send.buffer.bytes should be allowed to set -1
chia7712 commented on PR #13404:
URL: https://github.com/apache/kafka/pull/13404#issuecomment-1477457628
```
[2023-03-17T04:47:45.614Z] BUILD SUCCESSFUL in 1h 56m 35s
[2023-03-17T04:47:45.614Z] 224 actionable tasks: 120 executed, 104 up-to-date
```
tests pass. will merge it later
[
https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-14814:
--
Assignee: Chaitanya Mukka (was: Yash Mayya)
> Skip restart of connectors when redundant resu
chia7712 merged PR #13404:
URL: https://github.com/apache/kafka/pull/13404
--
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-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703107#comment-17703107
]
Yash Mayya commented on KAFKA-14814:
Hi [~cmukka20], I've re-assigned the ticket to
[
https://issues.apache.org/jira/browse/KAFKA-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-14812:
--
Assignee: hudeqi
> ProducerPerformance still counting successful sending in console w
mimaison merged PR #13422:
URL: https://github.com/apache/kafka/pull/13422
--
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
hudeqi closed pull request #13412: MINOR: Fix low bound in AdminClientConfig
and DistributedConfig
URL: https://github.com/apache/kafka/pull/13412
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atul Jain updated KAFKA-14597:
--
Attachment: image-2023-03-21-15-06-47-836.png
> [Streams] record-e2e-latency-max is not reporting corr
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atul Jain updated KAFKA-14597:
--
Attachment: image-2023-03-21-15-07-24-352.png
> [Streams] record-e2e-latency-max is not reporting corr
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atul Jain updated KAFKA-14597:
--
Attachment: (was: image-2023-03-21-15-06-47-836.png)
> [Streams] record-e2e-latency-max is not rep
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703118#comment-17703118
]
Atul Jain commented on KAFKA-14597:
---
Hi [~cadonna] ,
{quote}Could you run your Stream
hudeqi closed pull request #13377: MINOR: Fix typos in JaasContext
URL: https://github.com/apache/kafka/pull/13377
--
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 unsubscrib
tinaselenge commented on PR #13373:
URL: https://github.com/apache/kafka/pull/13373#issuecomment-1477564128
@mimaison @C0urante Thank you so much for reviewing the PR. I think I have
addressed all the review comments, please let me know if I have missed anything
or you have any further comm
hudeqi commented on PR #13427:
URL: https://github.com/apache/kafka/pull/13427#issuecomment-1477565223
Hello, please help to review. @guozhangwang
--
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
tinaselenge commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1143144850
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -514,6 +540,37 @@ private void updateTopicConfigs(Map
topicConfig
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703129#comment-17703129
]
Tales Tonini commented on KAFKA-14597:
--
Hi [~atuljainiitk] , may I ask what Kafka S
tinaselenge commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1143154814
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -514,6 +540,37 @@ private void updateTopicConfigs(Map
topicConfig
tinaselenge commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1143154814
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -514,6 +540,37 @@ private void updateTopicConfigs(Map
topicConfig
lucasbru commented on code in PR #13382:
URL: https://github.com/apache/kafka/pull/13382#discussion_r1143171856
##
clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java:
##
@@ -274,6 +282,13 @@ static public Serde UUID() {
return new UUIDSerde();
muralibasani commented on PR #13417:
URL: https://github.com/apache/kafka/pull/13417#issuecomment-1477601010
@mimaison PR is ready to review.
- Had to modify build.gradle to avoid circular dependency. As formatCommand
is being used in other classes in core module.
- There is an unrela
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703143#comment-17703143
]
Atul Jain commented on KAFKA-14597:
---
I currently have 2.6.0 version
> [Streams] recor
lucasbru commented on PR #13097:
URL: https://github.com/apache/kafka/pull/13097#issuecomment-1477637108
> 2. streams exception: translated from kafka exception from restore
consumer's other calls, as well as the restore callback)
`InvalidOffsetException` is rethrown as `StreamsExcept
lucasbru commented on code in PR #13369:
URL: https://github.com/apache/kafka/pull/13369#discussion_r1143208858
##
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskEOSMultiRebalanceIntegrationTest.java:
##
@@ -0,0 +1,304 @@
+/*
+ * Licensed to the Apache Sof
chia7712 commented on PR #13326:
URL: https://github.com/apache/kafka/pull/13326#issuecomment-1477661271
@showuon @mumrah Could 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 th
C0urante commented on PR #13425:
URL: https://github.com/apache/kafka/pull/13425#issuecomment-1477800891
--
This is an automated message from the Apache Git Service.
To respo
C0urante merged PR #13367:
URL: https://github.com/apache/kafka/pull/13367
--
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-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atul Jain updated KAFKA-14597:
--
Attachment: image-2023-03-21-19-01-54-713.png
> [Streams] record-e2e-latency-max is not reporting corr
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atul Jain updated KAFKA-14597:
--
Attachment: image-2023-03-21-19-03-07-525.png
> [Streams] record-e2e-latency-max is not reporting corr
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Atul Jain updated KAFKA-14597:
--
Attachment: image-2023-03-21-19-03-28-625.png
> [Streams] record-e2e-latency-max is not reporting corr
[
https://issues.apache.org/jira/browse/KAFKA-14597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703204#comment-17703204
]
Atul Jain commented on KAFKA-14597:
---
[~talestonini] I have another issue with process-
C0urante commented on PR #13367:
URL: https://github.com/apache/kafka/pull/13367#issuecomment-1477875999
Merged and backported to 3.3 and 3.4
--
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 s
[
https://issues.apache.org/jira/browse/KAFKA-14797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-14797.
---
Resolution: Fixed
> MM2 does not emit offset syncs when conservative translation logic excee
C0urante commented on PR #13420:
URL: https://github.com/apache/kafka/pull/13420#issuecomment-1477881989
(I did not notice that the KIP voting thread has not closed yet. This should
probably only be merged after that happens 😄)
--
This is an automated message from the Apache Git Service.
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1143623680
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -514,6 +540,37 @@ private void updateTopicConfigs(Map
topicConfigs)
mimaison commented on code in PR #13424:
URL: https://github.com/apache/kafka/pull/13424#discussion_r1143576130
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java:
##
@@ -103,6 +103,9 @@ public List> taskConfigs(int maxTasks) {
wcarlson5 commented on code in PR #13382:
URL: https://github.com/apache/kafka/pull/13382#discussion_r1143691894
##
streams/src/main/java/org/apache/kafka/streams/state/internals/NullableValueAndTimestampSerde.java:
##
@@ -48,42 +45,4 @@ public NullableValueAndTimestampSerde(fin
gharris1727 opened a new pull request, #13428:
URL: https://github.com/apache/kafka/pull/13428
The IdentityReplicationIntegrationTest nontrivially overrides two tests from
the Base test. Most of the implementation is copied, but modifications to the
copy change assertions that have to do wi
mimaison commented on PR #13419:
URL: https://github.com/apache/kafka/pull/13419#issuecomment-1478251287
Thanks for the review @C0urante !
I've now closed the voting thread. Even though they are not available here,
tests have
[run](https://ci-builds.apache.org/job/Kafka/job/kafka-pr/view
mukkachaitanya commented on PR #13426:
URL: https://github.com/apache/kafka/pull/13426#issuecomment-1478255352
Hi, @yashmayya / @C0urante let me know if you folks can take a stab at
reviewing the PR. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the me
mimaison merged PR #13419:
URL: https://github.com/apache/kafka/pull/13419
--
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-8713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-8713.
---
Fix Version/s: 3.5.0
Assignee: Mickael Maison
Resolution: Fixed
> [Connect] J
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143738304
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -207,6 +226,232 @@ public NetworkClientDelegate.UnsentRequest
t
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143739168
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -207,6 +226,232 @@ public NetworkClientDelegate.UnsentRequest
t
[
https://issues.apache.org/jira/browse/KAFKA-14585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703309#comment-17703309
]
Muralidhar Basani commented on KAFKA-14585:
---
[~mimaison] I think am done with
vcrfxia commented on code in PR #13340:
URL: https://github.com/apache/kafka/pull/13340#discussion_r1143766313
##
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java:
##
@@ -302,7 +319,54 @@ public void
shouldAllowCustomIQv2ForC
C0urante commented on code in PR #13426:
URL: https://github.com/apache/kafka/pull/13426#discussion_r1143794237
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaConfigBackingStoreTest.java:
##
@@ -889,6 +890,51 @@ public void testBackgroundUpdateTargetState
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1143650777
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java:
##
@@ -261,6 +326,78 @@ public void testNewTopicConfigs() throws Except
mimaison commented on PR #13420:
URL: https://github.com/apache/kafka/pull/13420#issuecomment-1478373825
I've now closed the voting thread. [Test
failures](https://ci-builds.apache.org/job/Kafka/job/kafka-pr/view/change-requests/job/PR-13420/1/testReport/)
are not related, merging to trunk.
mimaison merged PR #13420:
URL: https://github.com/apache/kafka/pull/13420
--
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-14740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-14740.
Fix Version/s: 3.5.0
Resolution: Fixed
> Missing source tag on MirrorSource metrics
C0urante commented on PR #13426:
URL: https://github.com/apache/kafka/pull/13426#issuecomment-1478385471
@yashmayya that's my bad, it does appear that you're correct and that the
`Connector` won't be restarted, but a request for new task configs will take
place.
IMO this change still
jsancio opened a new pull request, #13430:
URL: https://github.com/apache/kafka/pull/13430
To help debug KRaft's behavior this change increases the log level of some
rare messages to INFO level.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implemen
hachikuji commented on PR #13430:
URL: https://github.com/apache/kafka/pull/13430#issuecomment-1478403979
Upgrading the error messages is probably fair, but do we really need the
backoff messages at INFO level? Seems like they have potential to be noisy.
--
This is an automated message fr
jsancio commented on PR #13430:
URL: https://github.com/apache/kafka/pull/13430#issuecomment-1478413634
> Upgrading the error messages is probably fair, but do we really need the
backoff messages at INFO level? Seems like they have potential to be noisy.
Okay. I'll revert the change t
vcrfxia opened a new pull request, #13431:
URL: https://github.com/apache/kafka/pull/13431
The RocksDB-based versioned store implementation introduced in
https://github.com/apache/kafka/pull/13188 currently uses two physical RocksDB
instances per store instance: one for the "latest value st
hachikuji commented on PR #13430:
URL: https://github.com/apache/kafka/pull/13430#issuecomment-1478422374
> Okay. I'll revert the change to the send request backoff but I think we
should keep the candidate backoff as that is "rare" and would help us debug
election delays. What do you think?
vcrfxia commented on code in PR #13431:
URL: https://github.com/apache/kafka/pull/13431#discussion_r1143859781
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -821,4 +823,20 @@ public Options getOptions() {
public Position getPosit
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143865476
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -113,15 +112,45 @@ private void maybeAutoCommit(final long curre
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris reassigned KAFKA-14666:
---
Assignee: Greg Harris
> MM2 should translate consumer group offsets behind replication flow
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143865476
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -113,15 +112,45 @@ private void maybeAutoCommit(final long curre
C0urante commented on code in PR #13375:
URL: https://github.com/apache/kafka/pull/13375#discussion_r1143840978
##
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java:
##
@@ -152,11 +154,6 @@ public void stop() {
connectClust
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703339#comment-17703339
]
Greg Harris commented on KAFKA-14666:
-
I proposed a tactical fix for this in
[https
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703339#comment-17703339
]
Greg Harris edited comment on KAFKA-14666 at 3/21/23 7:08 PM:
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143881070
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -207,6 +226,232 @@ public NetworkClientDelegate.UnsentRequest
t
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703339#comment-17703339
]
Greg Harris edited comment on KAFKA-14666 at 3/21/23 7:13 PM:
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143888783
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -207,6 +226,232 @@ public NetworkClientDelegate.UnsentRequest
t
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143891018
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -137,31 +166,21 @@ CompletableFuture sendAutoCommit(final
Map t
Jason Gustafson created KAFKA-14830:
---
Summary: Illegal state error in transactional producer
Key: KAFKA-14830
URL: https://issues.apache.org/jira/browse/KAFKA-14830
Project: Kafka
Issue Typ
Jason Gustafson created KAFKA-14831:
---
Summary: Illegal state errors should be fatal in transactional
producer
Key: KAFKA-14831
URL: https://issues.apache.org/jira/browse/KAFKA-14831
Project: Kafka
C0urante commented on code in PR #13383:
URL: https://github.com/apache/kafka/pull/13383#discussion_r1143902556
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerSourceTaskTest.java:
##
@@ -315,33 +305,28 @@ public void testPause() throws Exception {
dimitarndimitrov opened a new pull request, #13432:
URL: https://github.com/apache/kafka/pull/13432
Aside from consistency with the implementation of newer APIs this also
provides more resilient retries (e.g. in case of TimeoutExceptions) and
simplifies the code to some extent.
One n
C0urante opened a new pull request, #13433:
URL: https://github.com/apache/kafka/pull/13433
- [Jira (cyclic schema
support)](https://issues.apache.org/jira/browse/KAFKA-3910)
- [Jira (default value for struct
schemas)](https://issues.apache.org/jira/browse/KAFKA-12694)
Implemented
C0urante commented on PR #13433:
URL: https://github.com/apache/kafka/pull/13433#issuecomment-1478577830
cc @urbandan; I've tweaked this a bit (stopped tracking equivalent schemas
while comparing default values since that was actually doing nothing and AFAICT
is unnecessary, and copied the
C0urante commented on PR #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-1478578470
Opened https://github.com/apache/kafka/pull/13433 to address this (and
cyclic schema support)
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/KAFKA-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-3910:
Assignee: Chris Egerton (was: Shikhar Bhushan)
> Cyclic schema support in ConnectSchema a
[
https://issues.apache.org/jira/browse/KAFKA-12694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-12694:
-
Assignee: Chris Egerton
> Specifying a struct-based defaultValue on a SchemaBuilder cau
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1143999124
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -137,31 +166,21 @@ CompletableFuture sendAutoCommit(final
Map t
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1144002857
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -207,6 +226,232 @@ public NetworkClientDelegate.UnsentRequest
t
SpacRocket commented on code in PR #13382:
URL: https://github.com/apache/kafka/pull/13382#discussion_r1144052014
##
streams/src/main/java/org/apache/kafka/streams/state/internals/NullableValueAndTimestampSerde.java:
##
@@ -48,42 +45,4 @@ public NullableValueAndTimestampSerde(fi
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13295:
--
Fix Version/s: (was: 4.0.0)
> Long restoration times for new tasks can lead to transaction
[
https://issues.apache.org/jira/browse/KAFKA-13295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703404#comment-17703404
]
Guozhang Wang commented on KAFKA-13295:
---
[~sagarrao] I had a chat with others driv
jsancio merged PR #13430:
URL: https://github.com/apache/kafka/pull/13430
--
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.
mjsax merged PR #13292:
URL: https://github.com/apache/kafka/pull/13292
--
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
mjsax merged PR #13409:
URL: https://github.com/apache/kafka/pull/13409
--
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-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703339#comment-17703339
]
Greg Harris edited comment on KAFKA-14666 at 3/22/23 12:12 AM:
---
kirktrue commented on PR #13425:
URL: https://github.com/apache/kafka/pull/13425#issuecomment-1478805465
@guozhangwang @hachikuji @rajinisivaram @philipnee This is ready for a
review from whomever has the time.
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-14824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703449#comment-17703449
]
hudeqi commented on KAFKA-14824:
For "potential exceptions may be throw", I did such an
[
https://issues.apache.org/jira/browse/KAFKA-14824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14824:
---
Attachment: 1.png
2.png
3.png
4.png
> ReplicaAlterLogDirsThr
[
https://issues.apache.org/jira/browse/KAFKA-14824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17703449#comment-17703449
]
hudeqi edited comment on KAFKA-14824 at 3/22/23 2:35 AM:
-
For "p
hudeqi commented on PR #13421:
URL: https://github.com/apache/kafka/pull/13421#issuecomment-1478842301
Hello, for "potential exceptions", I did an experiment to simulate a disk
failure, which eventually lead to the unexpected disk growing. For details,
please refer to the corresponding comm
[
https://issues.apache.org/jira/browse/KAFKA-14824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14824:
---
Summary: ReplicaAlterLogDirsThread may cause serious disk growing in case
of unknown exception (was: Replic
[
https://issues.apache.org/jira/browse/KAFKA-14824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi reassigned KAFKA-14824:
--
Assignee: hudeqi
> ReplicaAlterLogDirsThread may cause serious disk growing in case of potential
> e
1 - 100 of 103 matches
Mail list logo
