[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648357#comment-17648357
]
Endre Vig commented on KAFKA-14496:
---
[~kirktrue], thanks for acting so fast upon the ticket and
vamossagar12 commented on code in PR #12985:
URL: https://github.com/apache/kafka/pull/12985#discussion_r1050389751
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -159,7 +159,8 @@ public void send(final String topic,
akhileshchg commented on code in PR #12998:
URL: https://github.com/apache/kafka/pull/12998#discussion_r1050300078
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -88,14 +83,23 @@ private void initializeMigrationState() {
}
akhileshchg commented on code in PR #12998:
URL: https://github.com/apache/kafka/pull/12998#discussion_r1050297925
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -88,14 +83,23 @@ private void initializeMigrationState() {
}
akhileshchg commented on code in PR #13001:
URL: https://github.com/apache/kafka/pull/13001#discussion_r1050278848
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -703,8 +703,8 @@ class KafkaServer(
case None =>
info(s"Broker
akhileshchg commented on code in PR #13001:
URL: https://github.com/apache/kafka/pull/13001#discussion_r1050276330
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -703,8 +703,8 @@ class KafkaServer(
case None =>
info(s"Broker
cmccabe merged PR #12983:
URL: https://github.com/apache/kafka/pull/12983
--
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:
cmccabe commented on code in PR #13001:
URL: https://github.com/apache/kafka/pull/13001#discussion_r1050263765
##
core/src/main/scala/kafka/server/KafkaServer.scala:
##
@@ -703,8 +703,8 @@ class KafkaServer(
case None =>
info(s"Broker
cmccabe commented on code in PR #13001:
URL: https://github.com/apache/kafka/pull/13001#discussion_r1050263485
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -290,29 +295,27 @@ case class BrokerToControllerQueueItem(
)
class
bbejeck opened a new pull request, #13002:
URL: https://github.com/apache/kafka/pull/13002
This PR updates `StateQueryResult.getOnlyPartitionResult()` to not throw an
`IllegaArgumentException` when there are 0 query results.
Added a test that will fail without this patch
###
akhileshchg opened a new pull request, #13001:
URL: https://github.com/apache/kafka/pull/13001
…forwarding patch
Original patch: https://github.com/apache/kafka/pull/12961/files#
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kirktrue commented on PR #13000:
URL: https://github.com/apache/kafka/pull/13000#issuecomment-1353884809
@omkreddy - would you be willing to review? 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
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648297#comment-17648297
]
Kirk True commented on KAFKA-14496:
---
[~vendre] - I've made a pull request
kirktrue opened a new pull request, #13000:
URL: https://github.com/apache/kafka/pull/13000
The OAuth code to generate the `Authentication` header was incorrectly using
the URL-safe base64 encoder. For client IDs and/or secrets with dashes and/or
plus signs would not be encoded correctly,
ableegoldman commented on PR #12985:
URL: https://github.com/apache/kafka/pull/12985#issuecomment-1353835646
Cherrypicked to 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 specific
ableegoldman commented on PR #12977:
URL: https://github.com/apache/kafka/pull/12977#issuecomment-1353835301
Merged to trunk and cherrypicked to 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
ableegoldman commented on code in PR #12985:
URL: https://github.com/apache/kafka/pull/12985#discussion_r1050225672
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -159,7 +159,8 @@ public void send(final String topic,
ableegoldman merged PR #12977:
URL: https://github.com/apache/kafka/pull/12977
--
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-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-14496:
--
Priority: Blocker (was: Major)
> Wrong Base64 encoder used by OIDC OAuthBearerLoginCallbackHandler
>
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-14496:
-
Assignee: Kirk True
> Wrong Base64 encoder used by OIDC OAuthBearerLoginCallbackHandler
>
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648281#comment-17648281
]
Kirk True commented on KAFKA-14496:
---
[~vendre] - thanks for the timely response!
I appreciate your
cmccabe merged PR #12961:
URL: https://github.com/apache/kafka/pull/12961
--
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-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648245#comment-17648245
]
Endre Vig commented on KAFKA-14496:
---
[~kirktrue], there would be no technical issue for me to submit a
[
https://issues.apache.org/jira/browse/KAFKA-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648241#comment-17648241
]
Kirk True commented on KAFKA-14494:
---
[~taiga-elephant] - thanks for finding and reporting this! I
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648239#comment-17648239
]
Kirk True commented on KAFKA-14496:
---
[~vendre] - has been deemed a release blocker for AK 3.3.2 and
mumrah commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050096386
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -364,11 +399,13 @@ class BrokerToControllerRequestThread(
}
override def
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648231#comment-17648231
]
Kirk True commented on KAFKA-14496:
---
Thanks for catching this, Endre!
> Wrong Base64 encoder used by
ijuma commented on PR #12890:
URL: https://github.com/apache/kafka/pull/12890#issuecomment-1353646247
@divijvaidya Thanks. Can you please attach the html file? I think it's
possible to do it here, but if not then the JIRA would be helpful. I can take a
closer look on the bits that seemed a
Vincent Jiang created KAFKA-14497:
-
Summary: LastStableOffset is advanced prematurely when a log is
reopened.
Key: KAFKA-14497
URL: https://issues.apache.org/jira/browse/KAFKA-14497
Project: Kafka
mumrah commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050078269
##
core/src/main/scala/kafka/server/MetadataCache.scala:
##
@@ -103,13 +110,18 @@ trait MetadataCache {
def metadataVersion(): MetadataVersion
def features():
mumrah commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050076979
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -248,7 +258,12 @@ class ZkMetadataCache(brokerId: Int, metadataVersion:
MetadataVersion,
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050074366
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1318,14 +1317,20 @@ class KafkaApis(val requestChannel: RequestChannel,
trace("Sending topic
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050065115
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -248,7 +258,12 @@ class ZkMetadataCache(brokerId: Int, metadataVersion:
MetadataVersion,
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050065115
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -248,7 +258,12 @@ class ZkMetadataCache(brokerId: Int, metadataVersion:
MetadataVersion,
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050063855
##
core/src/main/scala/kafka/server/MetadataCache.scala:
##
@@ -103,13 +110,18 @@ trait MetadataCache {
def metadataVersion(): MetadataVersion
def
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050049320
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -364,11 +399,13 @@ class BrokerToControllerRequestThread(
}
override def
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050047950
##
core/src/main/scala/kafka/server/metadata/ZkMetadataCache.scala:
##
@@ -60,16 +60,24 @@ trait ZkFinalizedFeatureCache {
* A cache for the state (e.g.,
junrao commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1050008020
##
core/src/main/scala/kafka/log/UnifiedLog.scala:
##
@@ -574,6 +594,12 @@ class UnifiedLog(@volatile var logStartOffset: Long,
explicitMetricName(pkgStr, "Log",
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050037434
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -276,17 +290,38 @@ case class BrokerToControllerQueueItem(
)
class
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050036052
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -276,17 +290,38 @@ case class BrokerToControllerQueueItem(
)
class
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648208#comment-17648208
]
Endre Vig commented on KAFKA-14496:
---
[~omkreddy] I would be very glad to submit a fix.
> Wrong Base64
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050028258
##
core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala:
##
@@ -276,17 +290,38 @@ case class BrokerToControllerQueueItem(
)
class
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050026488
##
clients/src/main/resources/common/message/StopReplicaRequest.json:
##
@@ -31,7 +31,7 @@
"fields": [
{ "name": "ControllerId", "type": "int32",
akhileshchg commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1050026225
##
clients/src/main/resources/common/message/LeaderAndIsrRequest.json:
##
@@ -36,7 +36,7 @@
"fields": [
{ "name": "ControllerId", "type": "int32",
vamossagar12 opened a new pull request, #12999:
URL: https://github.com/apache/kafka/pull/12999
Reverts https://github.com/apache/kafka/pull/12803
--
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
vamossagar12 commented on code in PR #12802:
URL: https://github.com/apache/kafka/pull/12802#discussion_r1049987971
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -1645,6 +1646,8 @@ private void
gharris1727 commented on PR #12995:
URL: https://github.com/apache/kafka/pull/12995#issuecomment-1353446482
@ijuma Thanks for pointing that out. I never noticed any effects of the
OOMEs on the persistent JVM or other tests, but if I'm trying to de-flake the
tests, introducing a new kind of
divijvaidya commented on PR #12890:
URL: https://github.com/apache/kafka/pull/12890#issuecomment-1353397300
@ijuma yes, there was a warm up workload prior to profiling. The JVM was
probably alive for ~7-8 min. before the profile capture started. What are the
fishy things that you notice
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar updated KAFKA-14496:
--
Fix Version/s: 3.4.0
3.3.2
> Wrong Base64 encoder used by OIDC
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17648154#comment-17648154
]
Manikumar commented on KAFKA-14496:
---
[~vendre] Thanks for reporting the issue. Would you like to
C0urante commented on PR #12941:
URL: https://github.com/apache/kafka/pull/12941#issuecomment-1353348389
Thanks Mickael!
--
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
C0urante merged PR #12941:
URL: https://github.com/apache/kafka/pull/12941
--
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:
mumrah commented on code in PR #12961:
URL: https://github.com/apache/kafka/pull/12961#discussion_r1046431404
##
clients/src/main/resources/common/message/StopReplicaRequest.json:
##
@@ -31,7 +31,7 @@
"fields": [
{ "name": "ControllerId", "type": "int32", "versions":
ijuma commented on PR #12890:
URL: https://github.com/apache/kafka/pull/12890#issuecomment-1353303765
Was this profile taken after the broker was running for long enough for the
JIT compilation to have completed? The profile seems to show some things that
look a bit odd.
That said,
clolov commented on code in PR #12821:
URL: https://github.com/apache/kafka/pull/12821#discussion_r1049809566
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StateManagerUtilTest.java:
##
@@ -187,151 +139,92 @@ public void
dajac commented on PR #12865:
URL: https://github.com/apache/kafka/pull/12865#issuecomment-1353286898
@mimaison Will do.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14427.
--
Resolution: Fixed
> Add support for ZK migration multi-ops transaction
>
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reassigned KAFKA-14427:
Assignee: David Arthur (was: Colin McCabe)
> Add support for ZK migration multi-ops
[
https://issues.apache.org/jira/browse/KAFKA-14304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14304:
-
Fix Version/s: 3.4.1
(was: 3.4.0)
> ZooKeeper to KRaft Migration
>
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14427:
-
Fix Version/s: 3.4.0
(was: 3.4.1)
> Add support for ZK migration
[
https://issues.apache.org/jira/browse/KAFKA-14448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14448.
--
Resolution: Fixed
> ZK brokers register with KRaft during migration
>
[
https://issues.apache.org/jira/browse/KAFKA-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14428:
-
Fix Version/s: 3.4.0
> Add Records, RPCs and Configs for KIP-866
>
[
https://issues.apache.org/jira/browse/KAFKA-14447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14447:
-
Fix Version/s: 3.4.1
> Controlled shutdown for ZK brokers during migration
>
[
https://issues.apache.org/jira/browse/KAFKA-14448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14448:
-
Fix Version/s: 3.4.0
> ZK brokers register with KRaft during migration
>
[
https://issues.apache.org/jira/browse/KAFKA-14428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14428.
--
Resolution: Fixed
> Add Records, RPCs and Configs for KIP-866
>
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur reopened KAFKA-14427:
--
Assignee: Colin McCabe (was: David Arthur)
> Add support for ZK migration multi-ops
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14427:
-
Fix Version/s: 3.4.0
> Add support for ZK migration multi-ops transaction
>
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-14427:
-
Fix Version/s: 3.4.1
(was: 3.4.0)
> Add support for ZK migration
[
https://issues.apache.org/jira/browse/KAFKA-14427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur resolved KAFKA-14427.
--
Resolution: Fixed
> Add support for ZK migration multi-ops transaction
>
mimaison commented on PR #12865:
URL: https://github.com/apache/kafka/pull/12865#issuecomment-1353178569
@dajac Can we rebase this 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
Scanteianu commented on PR #12753:
URL: https://github.com/apache/kafka/pull/12753#issuecomment-1353147822
@showuon jdk17/scala 2.13 passed, and the failures in the other runs seem
unrelated
--
This is an automated message from the Apache Git Service.
To respond to the message, please
PhantomMaa commented on PR #12997:
URL: https://github.com/apache/kafka/pull/12997#issuecomment-1353022198
hi, those failed checks are not caused by my modification in this time.
what can i do next ?
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Endre Vig updated KAFKA-14496:
--
Description:
Currently our team is setting up a blueprint for our Kafka consumers/producers
to
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Endre Vig updated KAFKA-14496:
--
Description:
Currently our team is setting up a blueprint for our Kafka consumers/producers
to
[
https://issues.apache.org/jira/browse/KAFKA-14496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Endre Vig updated KAFKA-14496:
--
Attachment: base64test.zip
> Wrong Base64 encoder used by OIDC OAuthBearerLoginCallbackHandler
>
Endre Vig created KAFKA-14496:
-
Summary: Wrong Base64 encoder used by OIDC
OAuthBearerLoginCallbackHandler
Key: KAFKA-14496
URL: https://issues.apache.org/jira/browse/KAFKA-14496
Project: Kafka
divijvaidya commented on PR #12890:
URL: https://github.com/apache/kafka/pull/12890#issuecomment-1352933410
Hey @ijuma - thank you for your question.
1. I used [Amazon CodeGuru
Profiler](https://docs.aws.amazon.com/codeguru/latest/profiler-ug/what-is-codeguru-profiler.html).
I ran
[
https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-14466:
-
Assignee: Satish Duggana (was: Luke Chen)
> Refactor
[
https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647977#comment-17647977
]
Luke Chen edited comment on KAFKA-14466 at 12/15/22 10:01 AM:
--
I can also
[
https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647977#comment-17647977
]
Luke Chen commented on KAFKA-14466:
---
I can also help on this if you haven't started it yet.
>
[
https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647976#comment-17647976
]
Luke Chen commented on KAFKA-14467:
---
Discussed offline, I'm going to take over this task.
> Add a
[
https://issues.apache.org/jira/browse/KAFKA-14466?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen reassigned KAFKA-14466:
-
Assignee: Luke Chen (was: Satish Duggana)
> Refactor
[
https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17647965#comment-17647965
]
Satish Duggana commented on KAFKA-14467:
Sure [~showuon]. (y)
> Add a test to validate the
[
https://issues.apache.org/jira/browse/KAFKA-14467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana reassigned KAFKA-14467:
--
Assignee: Luke Chen (was: Satish Duggana)
> Add a test to validate the replica
divijvaidya closed pull request #12989: KAFKA-14469: Fix remote tiered related
topic configuration
URL: https://github.com/apache/kafka/pull/12989
--
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
divijvaidya commented on PR #12989:
URL: https://github.com/apache/kafka/pull/12989#issuecomment-1352777373
Thanks @satishd. I will discard this PR in that case. When you get a chance,
please update the KIP to make it consistent with the above.
--
This is an automated message from the
showuon commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1049396894
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -0,0 +1,224 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
Luke Chen created KAFKA-14495:
-
Summary: Improve the RemoteIndexCacheTest
Key: KAFKA-14495
URL: https://issues.apache.org/jira/browse/KAFKA-14495
Project: Kafka
Issue Type: Sub-task
showuon commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1049393028
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -0,0 +1,229 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
showuon commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r1049392445
##
core/src/test/scala/unit/kafka/log/remote/RemoteIndexCacheTest.scala:
##
@@ -0,0 +1,224 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or
[
https://issues.apache.org/jira/browse/KAFKA-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Zhovtanyuk updated KAFKA-14494:
Description:
When Kafka Java client sits behind the SOCK5 proxy, it connects to the
[
https://issues.apache.org/jira/browse/KAFKA-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Zhovtanyuk updated KAFKA-14494:
Description:
When Kafka Java client sits behind the SOCK5 proxy, it connects to the
mimaison merged PR #12895:
URL: https://github.com/apache/kafka/pull/12895
--
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-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Zhovtanyuk updated KAFKA-14494:
Attachment: kafka-client-java-direct.log.gz
kafka-client-java-socks.log.gz
[
https://issues.apache.org/jira/browse/KAFKA-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Zhovtanyuk updated KAFKA-14494:
Description:
When Kafka Java client sits behind the SOCK5 proxy, it connects to the
dajac merged PR #12858:
URL: https://github.com/apache/kafka/pull/12858
--
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-14494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Zhovtanyuk updated KAFKA-14494:
Attachment: client-java.tar.gz
client-nodejs.tar.gz
> Kafka Java client
97 matches
Mail list logo
