chia7712 commented on PR #13398:
URL: https://github.com/apache/kafka/pull/13398#issuecomment-1471424149
@garyparrot nice catch. It is not only typo but also incorrect validation.
the `atLeast(0)` disables users to input `-1` for socket buffer. Hence, this PR
is fixing a `bug` rather than a
robobario commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471424085
Maybe my thread safety explanation is incorrect, I'll look again tomorrow.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
chia7712 commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471425767
> Maybe my thread safety explanation is incorrect, I'll look again tomorrow.
the thread safety explanation is correct to me. My point was that we should
not only fix `iteration` bu
hudeqi commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471428193
> > Maybe my thread safety explanation is incorrect, I'll look again
tomorrow.
>
> the thread safety explanation is correct to me. My point was that we
should not only fix `iteratio
chia7712 commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471448616
> If all variables are volatile or atomic, will it affect the printing
performance of this perf program?
Or we just handle the `iteration` as it seems `iteration` is the only
vari
hudeqi commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471460665
>
> > If all variables are volatile or atomic, will it affect the printing
performance of this perf program?
>
> Or we just handle the `iteration` as it seems `iterat
chia7712 commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471465952
> In addition, does this repair need to open a new jira?
In fact, we should revert this PR first. The solution offered by this PR
bring antoher issue (thanks to @robobario). The or
hudeqi commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471469700
> > In addition, does this repair need to open a new jira?
>
> In fact, we should revert this PR first. The solution offered by this PR
bring antoher issue (thanks to @robobario). Th
chia7712 opened a new pull request, #13400:
URL: https://github.com/apache/kafka/pull/13400
Reverts apache/kafka#13348
#13348 brings another issue.
```
[2023-03-16 07:44:19,926] ERROR Error executing user-provided callback on
message for topic-partition 'perf-test-3'
(org.apach
chia7712 commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1471470912
> and then report back the original problem that failed to send but still
recorded success, and solve the current problem at the same time, right?
yep. #13400 is used to revert thi
chia7712 commented on PR #13400:
URL: https://github.com/apache/kafka/pull/13400#issuecomment-1471471412
@showuon PTAL
--
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 un
hudeqi commented on PR #13400:
URL: https://github.com/apache/kafka/pull/13400#issuecomment-1471474675
ok, I will submit a new jira and a pr.
--
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
hudeqi created KAFKA-14812:
--
Summary: ProducerPerformance still counting successful sending in
console when sending failed
Key: KAFKA-14812
URL: https://issues.apache.org/jira/browse/KAFKA-14812
Project: Kaf
[
https://issues.apache.org/jira/browse/KAFKA-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14812:
---
Attachment: WechatIMG27.jpeg
> ProducerPerformance still counting successful sending in console when sending
hudeqi commented on PR #13400:
URL: https://github.com/apache/kafka/pull/13400#issuecomment-1471559067
Hello, I have created a new
[JIRA](https://issues.apache.org/jira/browse/KAFKA-14812) here, can this revert
pr be executed? And I will submit a new pr based on the trunk, thank you.
@chia
[
https://issues.apache.org/jira/browse/KAFKA-14812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
hudeqi updated KAFKA-14812:
---
Issue Type: Bug (was: Improvement)
> ProducerPerformance still counting successful sending in console when
showuon commented on PR #13400:
URL: https://github.com/apache/kafka/pull/13400#issuecomment-1471596731
Yes, I'll merge it after CI test passed. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to
lucasbru commented on code in PR #13369:
URL: https://github.com/apache/kafka/pull/13369#discussion_r1138444392
##
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java:
##
@@ -280,6 +280,13 @@ synchronized void close(final String namespace) {
lucasbru commented on PR #13347:
URL: https://github.com/apache/kafka/pull/13347#issuecomment-1471705490
@guozhangwang ping?
--
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.
chia7712 opened a new pull request, #13401:
URL: https://github.com/apache/kafka/pull/13401
This reverts commit 8e4c0d0b04580cde1e15e7b4793bae747d38999c.
#13348 brings another issue.
```
[2023-03-16 07:44:19,926] ERROR Error executing user-provided callback on
message for topic-
chia7712 closed pull request #13400: Revert "MINOR: Fix ProducerPerformance
still counting successful sending when sending failed"
URL: https://github.com/apache/kafka/pull/13400
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
chia7712 commented on PR #13400:
URL: https://github.com/apache/kafka/pull/13400#issuecomment-1471744939
close as I forgot to file PR from my repo...
#13401
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
U
hudeqi commented on PR #13401:
URL: https://github.com/apache/kafka/pull/13401#issuecomment-1471765926
mark
--
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,
andymg3 opened a new pull request, #13402:
URL: https://github.com/apache/kafka/pull/13402
### Details
Updates `ReplicationControlManager` and `PartitionReassignmentReplicas` to
use `PartitionAssignment` which was introduced in
https://github.com/apache/kafka/pull/12892
### Testin
[
https://issues.apache.org/jira/browse/KAFKA-14799?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14799:
--
Fix Version/s: 3.4.1
3.3.3
> Source tasks fail if connector attempts to abo
[
https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701151#comment-17701151
]
Chris Egerton commented on KAFKA-14809:
---
This is arguably the root cause of KAFKA-
C0urante merged PR #13386:
URL: https://github.com/apache/kafka/pull/13386
--
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
C0urante commented on PR #13386:
URL: https://github.com/apache/kafka/pull/13386#issuecomment-1471890863
Thanks @hgeraldino, I've merged and backported as far back as applicable.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
[
https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-14809.
---
Resolution: Fixed
> Connect incorrectly logs that no records were produced by source tasks
>
[
https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14809:
--
Affects Version/s: 3.3.2
3.3.1
3.2.3
[
https://issues.apache.org/jira/browse/KAFKA-14809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14809:
--
Fix Version/s: 3.2.4
3.1.3
3.0.3
3.5.0
dajac commented on PR #13323:
URL: https://github.com/apache/kafka/pull/13323#issuecomment-1471913482
Failed tests are not related to this PR:
```
[Build / JDK 17 and Scala 2.13 / kafka.zk.ZkMigrationIntegrationTest.[1]
Type=ZK, Name=testDualWrite, MetadataVersion=3.4-IV0,
Security=PL
dajac merged PR #13323:
URL: https://github.com/apache/kafka/pull/13323
--
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
mimaison merged PR #13389:
URL: https://github.com/apache/kafka/pull/13389
--
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 #13401:
URL: https://github.com/apache/kafka/pull/13401#issuecomment-1471950362
https://ci-builds.apache.org/blue/organizations/jenkins/Kafka%2Fkafka-pr/detail/PR-13401/1/pipeline/13
`Build / JDK 17 and Scala 2.13` has passed. will merge it.
--
This is an a
chia7712 merged PR #13401:
URL: https://github.com/apache/kafka/pull/13401
--
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 opened a new pull request, #13403:
URL: https://github.com/apache/kafka/pull/13403
Since TopicCommand does not support updating the configuration of an
existing topic, "and/or configuration for the topic." should be removed from
the description of --alter, otherwise it will cause mis
hudeqi opened a new pull request, #13404:
URL: https://github.com/apache/kafka/pull/13404
When using ProducerPerformance, I found that when the sending fails, it is
still counted as successfully sent by stat and the metrics are printed in
console. For example, when there is no write permiss
hudeqi commented on PR #13404:
URL: https://github.com/apache/kafka/pull/13404#issuecomment-1472060451
About issues in #13348 , my solution is: remove the use of the iteration
variable of stats from the main thread, the read and write it completely by the
callback of a separate producer thr
hzh0425 closed pull request #13342: MINOR: Parse file offset of Remote Index as
Long type instead of Int type in RemoteIndexCache
URL: https://github.com/apache/kafka/pull/13342
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
Nicola Stringari created KAFKA-14813:
Summary: Timeout Exception causes data loss
Key: KAFKA-14813
URL: https://issues.apache.org/jira/browse/KAFKA-14813
Project: Kafka
Issue Type: Bug
chia7712 opened a new pull request, #13405:
URL: https://github.com/apache/kafka/pull/13405
related to https://issues.apache.org/jira/browse/KAFKA-14811
We don't check the in-flight requests when closing stale network client. If
the in-flight requests are related to metadata request f
pprovenzano closed pull request #13338: KAFKA-14765: Support SCRAM for brokers
at bootstrap
URL: https://github.com/apache/kafka/pull/13338
--
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 specif
chia7712 commented on code in PR #13404:
URL: https://github.com/apache/kafka/pull/13404#discussion_r1138878548
##
tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java:
##
@@ -113,7 +113,7 @@ void start(String[] args) throws IOException {
record =
chia7712 commented on PR #13404:
URL: https://github.com/apache/kafka/pull/13404#issuecomment-1472201788
@robobario please take a look if you have free cycle.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
C0urante commented on code in PR #13367:
URL: https://github.com/apache/kafka/pull/13367#discussion_r1138945859
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationTransactionsTest.java:
##
@@ -45,7 +45,13 @@ public void startCl
C0urante commented on code in PR #13367:
URL: https://github.com/apache/kafka/pull/13367#discussion_r1138946676
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationTransactionsTest.java:
##
@@ -45,7 +45,13 @@ public void startCl
[
https://issues.apache.org/jira/browse/KAFKA-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701271#comment-17701271
]
Chris Egerton commented on KAFKA-14666:
---
This is touched on more extensively in a
CalvinConfluent opened a new pull request, #13406:
URL: https://github.com/apache/kafka/pull/13406
As the second part of the
[KIP-903](https://cwiki.apache.org/confluence/display/KAFKA/KIP-903%3A+Replicas+with+stale+broker+epoch+should+not+be+allowed+to+join+the+ISR),
it updates the AlterPa
cmccabe merged PR #13394:
URL: https://github.com/apache/kafka/pull/13394
--
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-14666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-14666:
Labels: (was: needs-kip)
> MM2 should translate consumer group offsets behind replication flow
>
CalvinConfluent commented on PR #13406:
URL: https://github.com/apache/kafka/pull/13406#issuecomment-1472363308
Will send the API change and the controller side change first.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
CalvinConfluent closed pull request #13406: KAFKA-14617: Fill brokerEpoch in
AlterPartitionRequest
URL: https://github.com/apache/kafka/pull/13406
--
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
C0urante commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1139041573
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConfig.java:
##
@@ -73,6 +73,18 @@ public class MirrorSourceConfig extends
MirrorConnector
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701313#comment-17701313
]
Siddharth Anand commented on KAFKA-14757:
-
Hi [~pnee]
We implemented onPartitio
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701313#comment-17701313
]
Siddharth Anand edited comment on KAFKA-14757 at 3/16/23 5:35 PM:
ivanyu commented on code in PR #13362:
URL: https://github.com/apache/kafka/pull/13362#discussion_r1139132047
##
storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/serialization/RemoteLogMetadataSerde.java:
##
@@ -107,4 +110,13 @@ private RemoteLogMetadata
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701313#comment-17701313
]
Siddharth Anand edited comment on KAFKA-14757 at 3/16/23 5:41 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701313#comment-17701313
]
Siddharth Anand edited comment on KAFKA-14757 at 3/16/23 5:42 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701313#comment-17701313
]
Siddharth Anand edited comment on KAFKA-14757 at 3/16/23 6:00 PM:
[
https://issues.apache.org/jira/browse/KAFKA-14757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701313#comment-17701313
]
Siddharth Anand edited comment on KAFKA-14757 at 3/16/23 6:05 PM:
divijvaidya commented on PR #13362:
URL: https://github.com/apache/kafka/pull/13362#issuecomment-1472489702
@satishd perhaps you would like to review this since it's associated with
KIP405?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
tinaselenge commented on code in PR #13373:
URL: https://github.com/apache/kafka/pull/13373#discussion_r1139190436
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -117,6 +122,16 @@ public MirrorSourceConnector() {
this.c
mumrah opened a new pull request, #13407:
URL: https://github.com/apache/kafka/pull/13407
This patch adds the concepts of pre-migration mode to the KRaft controller.
While in this mode, the controller will only allow certain write operations.
The purpose of this is to disallow metadata chan
Chris Egerton created KAFKA-14814:
-
Summary: Skip restart of connectors when redundant resume request
is made
Key: KAFKA-14814
URL: https://issues.apache.org/jira/browse/KAFKA-14814
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14814:
--
Priority: Minor (was: Major)
> Skip restart of connectors when redundant resume request is ma
[
https://issues.apache.org/jira/browse/KAFKA-14814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-14814:
-
Assignee: (was: Chris Egerton)
> Skip restart of connectors when redundant resume r
mumrah commented on PR #13372:
URL: https://github.com/apache/kafka/pull/13372#issuecomment-1472608583
@cmccabe the latest test run fixed the unit test. The other failures will be
addressed by #13407
--
This is an automated message from the Apache Git Service.
To respond to the message,
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1139257566
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -235,4 +373,105 @@ public void ack(final long currentTimeMs) {
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1139276421
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -80,16 +97,18 @@ public CommitRequestManager(
*/
@Ove
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1139280595
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -235,4 +373,105 @@ public void ack(final long currentTimeMs) {
Jorge Esteban Quilcate Otoya created KAFKA-14815:
Summary: Move Kafka documentation to Markdown/Hugo
Key: KAFKA-14815
URL: https://issues.apache.org/jira/browse/KAFKA-14815
Project: Ka
robobario commented on PR #13404:
URL: https://github.com/apache/kafka/pull/13404#issuecomment-1472733211
> @robobario please take a look if you have free cycle.
LGTM. If you expose the internals of `Stats` a bit more we could test it
with something like:
```
@Test
pu
[
https://issues.apache.org/jira/browse/KAFKA-14523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701393#comment-17701393
]
Muralidhar Basani commented on KAFKA-14523:
---
Hi [~satish.duggana] , I see this
cmccabe merged PR #13372:
URL: https://github.com/apache/kafka/pull/13372
--
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.
mumrah commented on PR #13390:
URL: https://github.com/apache/kafka/pull/13390#issuecomment-1472771486
With the latest code, I got the following threads in KRaft mode:
```
"metrics-meter-tick-thread-1" #19 daemon prio=5 os_prio=31 cpu=0.57ms
elapsed=9.63s tid=0x00012608ce00 nid
gharris1727 commented on PR #13367:
URL: https://github.com/apache/kafka/pull/13367#issuecomment-1472825496
@C0urante I refactored it so that we have zero and nonzero test cases in
each suite. There's a little bit of duplication around the
IdentityReplicationIntegrationTest that i'll addres
[
https://issues.apache.org/jira/browse/KAFKA-13913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17701409#comment-17701409
]
Kirk True commented on KAFKA-13913:
---
[~frosiere] what's the status of the accompanying
gharris1727 commented on code in PR #13367:
URL: https://github.com/apache/kafka/pull/13367#discussion_r1139409839
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/integration/MirrorConnectorsIntegrationTransactionsTest.java:
##
@@ -45,7 +45,13 @@ public void star
CalvinConfluent opened a new pull request, #13408:
URL: https://github.com/apache/kafka/pull/13408
As the second part of the
[KIP-903](https://cwiki.apache.org/confluence/display/KAFKA/KIP-903%3A+Replicas+with+stale+broker+epoch+should+not+be+allowed+to+join+the+ISR),
it updates the AlterPa
guozhangwang commented on PR #13318:
URL: https://github.com/apache/kafka/pull/13318#issuecomment-1472839086
ping @cadonna for a final look, this PR needs to go first before the next
one.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
guozhangwang commented on PR #13318:
URL: https://github.com/apache/kafka/pull/13318#issuecomment-1472840025
> I triggered one now:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder//console
@lucasbru the failure seems not related to the code but sock timeouts
its
cmccabe merged PR #13390:
URL: https://github.com/apache/kafka/pull/13390
--
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.
cmccabe commented on PR #13390:
URL: https://github.com/apache/kafka/pull/13390#issuecomment-1472852676
Thanks, @mumrah . I did another quick sweep of the thread named, like you
did, and deleted the extra dash in one case, and added a dash in another. There
are still a few ugly and/or unpre
cmccabe commented on PR #13390:
URL: https://github.com/apache/kafka/pull/13390#issuecomment-1472853759
> Did you find where the lone EventHandler is coming from?
Sorry, I meant to respond to this comment earlier. But for completeness, the
lone EventHandler is gone now, last I checked
imcdo commented on code in PR #12828:
URL: https://github.com/apache/kafka/pull/12828#discussion_r1139460592
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java:
##
@@ -43,10 +43,38 @@
import java.util.concurrent.ExecutionException;
import ja
C0urante commented on code in PR #12828:
URL: https://github.com/apache/kafka/pull/12828#discussion_r1139465010
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java:
##
@@ -43,10 +43,38 @@
import java.util.concurrent.ExecutionException;
import
imcdo commented on code in PR #12828:
URL: https://github.com/apache/kafka/pull/12828#discussion_r1139470073
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java:
##
@@ -43,10 +43,38 @@
import java.util.concurrent.ExecutionException;
import ja
imcdo commented on code in PR #12828:
URL: https://github.com/apache/kafka/pull/12828#discussion_r1139476999
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java:
##
@@ -43,10 +43,38 @@
import java.util.concurrent.ExecutionException;
import ja
Ian McDonald created KAFKA-14816:
Summary: Connect Http Client
Key: KAFKA-14816
URL: https://issues.apache.org/jira/browse/KAFKA-14816
Project: Kafka
Issue Type: Bug
Components: Ka
[
https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ian McDonald updated KAFKA-14816:
-
Summary: Connect Http Client loading SSL data when security protocol
doesn't include ssl (was:
[
https://issues.apache.org/jira/browse/KAFKA-14816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ian McDonald updated KAFKA-14816:
-
Summary: Connect Http Client loading SSL configs when security protocol
doesn't include ssl (wa
imcdo commented on code in PR #12828:
URL: https://github.com/apache/kafka/pull/12828#discussion_r1139476999
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java:
##
@@ -43,10 +43,38 @@
import java.util.concurrent.ExecutionException;
import ja
guozhangwang commented on code in PR #13369:
URL: https://github.com/apache/kafka/pull/13369#discussion_r1139441498
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java:
##
@@ -590,12 +590,13 @@ void recycle() {
}
}
-
vcrfxia opened a new pull request, #13409:
URL: https://github.com/apache/kafka/pull/13409
Prior to this PR, versioned stores always returned null for `get(key,
timestamp)` calls where the timestamp has exceeded the store's history
retention, even if the latest value for the key (i.e., the
hgeraldino commented on code in PR #13294:
URL: https://github.com/apache/kafka/pull/13294#discussion_r1139545378
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/rest/RestClientTest.java:
##
@@ -157,23 +161,55 @@ private void setupHttpClient(int responseCode, S
showuon commented on PR #13362:
URL: https://github.com/apache/kafka/pull/13362#issuecomment-1472989118
I'll take a look this week.
--
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 co
mjsax commented on code in PR #13409:
URL: https://github.com/apache/kafka/pull/13409#discussion_r1139545717
##
streams/src/main/java/org/apache/kafka/streams/state/VersionedKeyValueStore.java:
##
@@ -59,12 +59,15 @@
* Delete the value associated with this key from the sto
hudeqi commented on PR #13404:
URL: https://github.com/apache/kafka/pull/13404#issuecomment-1473033928
Thank you both for your valuable comments! I have added optimization.
@chia7712 @robobario
--
This is an automated message from the Apache Git Service.
To respond to the message, please
philipnee commented on code in PR #13380:
URL: https://github.com/apache/kafka/pull/13380#discussion_r1139650990
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -137,31 +144,40 @@ CompletableFuture sendAutoCommit(final
Map t
1 - 100 of 114 matches
Mail list logo
