chia7712 commented on pull request #9365:
URL: https://github.com/apache/kafka/pull/9365#issuecomment-721617530
Is it similar to https://issues.apache.org/jira/browse/KAFKA-10090?
This is an automated message from the Apache
chia7712 commented on a change in pull request #9547:
URL: https://github.com/apache/kafka/pull/9547#discussion_r517212012
##
File path:
clients/src/main/resources/common/message/OffsetForLeaderEpochRequest.json
##
@@ -32,13 +32,13 @@
{ "name": "Topics", "type": "[]Offset
chia7712 commented on pull request #8953:
URL: https://github.com/apache/kafka/pull/8953#issuecomment-721626362
```EosBetaUpgradeIntegrationTest``` gets unstable recently. Maybe we should
re-disable it again :(
This is an au
tombentley commented on pull request #9365:
URL: https://github.com/apache/kafka/pull/9365#issuecomment-721626482
@chia7712 I think there's overlap, but I think this one removes additional
warnings because it also propagates usage tracking in `SslFactory`. (It also
provides a non-public ab
soarez commented on pull request #9000:
URL: https://github.com/apache/kafka/pull/9000#issuecomment-721637971
> Took way to long to get this merged.
My fault for screwing up several times. Thanks for not giving up on this and
all the time dedicated to reviewing.
---
bbejeck commented on a change in pull request #9554:
URL: https://github.com/apache/kafka/pull/9554#discussion_r517339026
##
File path: docs/streams/developer-guide/testing.html
##
@@ -73,67 +71,55 @@ // Processor
API
Topology topology = new Topology();
topology.addSource("s
bbejeck commented on a change in pull request #9554:
URL: https://github.com/apache/kafka/pull/9554#discussion_r517339602
##
File path: docs/streams/upgrade-guide.html
##
@@ -135,14 +134,12 @@ Streams API
tasks to their new owners in the background. Check out https://c
bbejeck merged pull request #9554:
URL: https://github.com/apache/kafka/pull/9554
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
bbejeck commented on pull request #9554:
URL: https://github.com/apache/kafka/pull/9554#issuecomment-721732656
Merged #9554 into trunk
This is an automated message from the Apache Git Service.
To respond to the message, pleas
bbejeck commented on pull request #9554:
URL: https://github.com/apache/kafka/pull/9554#issuecomment-721734486
cherry-picked to 2.7
This is an automated message from the Apache Git Service.
To respond to the message, please l
dajac commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517317354
##
File path: core/src/main/scala/kafka/network/RequestConvertToJson.scala
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
cadonna commented on a change in pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#discussion_r517426911
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -145,7 +145,7 @@
private final String clientId;
private final
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r517462186
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -317,6 +317,9 @@ private void appendLeaderChangeMessage(LeaderState s
cadonna commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517464968
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java
##
@@ -19,7 +19,7 @@
pu
vamossagar12 commented on a change in pull request #9539:
URL: https://github.com/apache/kafka/pull/9539#discussion_r517462186
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -317,6 +317,9 @@ private void appendLeaderChangeMessage(LeaderState s
[
https://issues.apache.org/jira/browse/KAFKA-10679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck reassigned KAFKA-10679:
---
Assignee: Bill Bejeck
> AK site docs changes need to get ported to Kafka/docs
> ---
wcarlson5 commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517481718
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -366,6 +374,66 @@ public void setUncaughtExceptionHandler(final
Thre
wcarlson5 commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517485257
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -997,6 +1064,72 @@ private boolean close(final long timeoutMs) {
Carlo Bongiovanni created KAFKA-10681:
-
Summary: MM2 translateOffsets returns wrong offsets
Key: KAFKA-10681
URL: https://issues.apache.org/jira/browse/KAFKA-10681
Project: Kafka
Issue Ty
wcarlson5 commented on a change in pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#discussion_r517516580
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -719,8 +718,7 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#issuecomment-721881768
@cadonna Looks like all those changes made sense
This is an automated message from the Apache Git Service.
To re
[
https://issues.apache.org/jira/browse/KAFKA-7556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reassigned KAFKA-7556:
-
Assignee: Justine Olshan
> KafkaConsumer.beginningOffsets does not return actual first o
vvcephei commented on a change in pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#discussion_r517539432
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -719,8 +718,7 @@ private KafkaStreams(final InternalTopologyBuilder
i
ableegoldman commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517543638
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java
##
@@ -19,7 +19,7 @
ableegoldman commented on pull request #8953:
URL: https://github.com/apache/kafka/pull/8953#issuecomment-721896700
I believe @mjsax is planning to look into it after his current work, but it
seems reasonable to disable it again until then
-
niteshmor opened a new pull request #9556:
URL: https://github.com/apache/kafka/pull/9556
Jetty 9.4.32 and before are affected by CVE-2020-27216. This vulnerability
is fixed in Jetty 9.4.33, please see the jetty project security advisory for
details:
https://github.com/eclipse/jetty.proje
niteshmor commented on pull request #9556:
URL: https://github.com/apache/kafka/pull/9556#issuecomment-721898016
For applying this fix to older branches, this commit can be cherry-picked to
`2.7` branch. For branches `2.6` and earlier, `jersey` version also needs to
be
upgraded to `2
niteshmor commented on pull request #9556:
URL: https://github.com/apache/kafka/pull/9556#issuecomment-721900447
cc @ijuma @kkonstantine @rhauch @C0urante
This is an automated message from the Apache Git Service.
To respond
navin created KAFKA-10682:
-
Summary: Windows Kafka cluster not reachable via Azure data Bricks
Key: KAFKA-10682
URL: https://issues.apache.org/jira/browse/KAFKA-10682
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
navin updated KAFKA-10682:
--
Description:
We have windows Kafka cluster,
* We enabled inbound and outbound for port 9092/9093
* Topic ret
[
https://issues.apache.org/jira/browse/KAFKA-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
navin updated KAFKA-10682:
--
Description:
We have windows Kafka cluster,
* We enabled inbound and outbound for port 9092/9093
* Topic ret
cmccabe opened a new pull request #9557:
URL: https://github.com/apache/kafka/pull/9557
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
cmccabe closed pull request #9557:
URL: https://github.com/apache/kafka/pull/9557
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
mikebin commented on pull request #8690:
URL: https://github.com/apache/kafka/pull/8690#issuecomment-721907104
Looks like this is still pending completion? Just wanted to check on status
of getting this merged.
This is an au
[
https://issues.apache.org/jira/browse/KAFKA-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226342#comment-17226342
]
navin commented on KAFKA-10682:
---
uncommented below command in server-properties located a
[
https://issues.apache.org/jira/browse/KAFKA-10682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
navin resolved KAFKA-10682.
---
Resolution: Fixed
kafka\config
Add
listeners = PLAINTEXT://10.53.56.140:9092
> Windows Kafka cluster not
lbradstreet commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517562348
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -380,8 +380,9 @@ private void generateVariableLengthTa
lbradstreet commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517562348
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -380,8 +380,9 @@ private void generateVariableLengthTa
wcarlson5 commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517576758
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java
##
@@ -311,6 +317,22 @@ public void run() {
bbejeck merged pull request #9544:
URL: https://github.com/apache/kafka/pull/9544
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
bbejeck commented on pull request #9544:
URL: https://github.com/apache/kafka/pull/9544#issuecomment-721937375
Merged #9544 into trunk
This is an automated message from the Apache Git Service.
To respond to the message, pleas
rajinisivaram commented on pull request #7751:
URL: https://github.com/apache/kafka/pull/7751#issuecomment-721940645
Streams test failure not related, merging to trunk.
This is an automated message from the Apache Git Service
rajinisivaram merged pull request #7751:
URL: https://github.com/apache/kafka/pull/7751
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
rajinisivaram closed pull request #9550:
URL: https://github.com/apache/kafka/pull/9550
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
Gary Russell created KAFKA-10683:
Summary: Consumer.position() Ignores Transaction Marker with
read_uncommitted
Key: KAFKA-10683
URL: https://issues.apache.org/jira/browse/KAFKA-10683
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-7987.
---
Fix Version/s: 2.8.0
Reviewer: Jun Rao
Resolution: Fixed
> a broker's ZK sess
wcarlson5 commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517621757
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -294,7 +304,10 @@ public static StreamThread cre
wcarlson5 commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r517627843
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/StreamsAssignmentProtocolVersions.java
##
@@ -19,7 +19,7 @@
wcarlson5 commented on a change in pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#discussion_r517629961
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -719,8 +718,7 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on a change in pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#discussion_r517630194
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -783,12 +781,13 @@ private KafkaStreams(final InternalTopologyBuilder
wcarlson5 commented on a change in pull request #9543:
URL: https://github.com/apache/kafka/pull/9543#discussion_r517630320
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -783,12 +781,13 @@ private KafkaStreams(final InternalTopologyBuilder
junrao commented on pull request #8826:
URL: https://github.com/apache/kafka/pull/8826#issuecomment-721987780
@chia7712 : Thanks for the PR.
I ran the following command with the PR.
bin/kafka-topics.sh --bootstrap-server localhost:9092 --command-config
kafka.properties --create -
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517645718
##
File path: core/src/main/scala/kafka/network/RequestConvertToJson.scala
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517649219
##
File path: core/src/main/scala/kafka/network/RequestConvertToJson.scala
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517651742
##
File path: core/src/main/scala/kafka/network/RequestConvertToJson.scala
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
niteshmor edited a comment on pull request #9556:
URL: https://github.com/apache/kafka/pull/9556#issuecomment-721898016
For applying this fix to older branches, this commit can be cherry-picked to
`2.7` branch. For branches `2.6` and earlier, `jersey` version also needs to
be
upgrade
niteshmor commented on pull request #9556:
URL: https://github.com/apache/kafka/pull/9556#issuecomment-721998495
Test failure seems to be unrelated.
`java.nio.file.DirectoryNotEmptyException` in
`org.apache.kafka.streams.integration.StreamTableJoinTopologyOptimizationIntegrationTest
abbccdda commented on pull request #9103:
URL: https://github.com/apache/kafka/pull/9103#issuecomment-722005317
Mvn failure is not related, merging
This is an automated message from the Apache Git Service.
To respond to the m
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517665383
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -380,8 +380,9 @@ private void generateVariableLengthT
abbccdda merged pull request #9103:
URL: https://github.com/apache/kafka/pull/9103
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
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517665383
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -380,8 +380,9 @@ private void generateVariableLengthT
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517665383
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -380,8 +380,9 @@ private void generateVariableLengthT
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517651742
##
File path: core/src/main/scala/kafka/network/RequestConvertToJson.scala
##
@@ -0,0 +1,360 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r517672247
##
File path: core/src/main/scala/kafka/snapshot/KafkaSnapshotReader.scala
##
@@ -0,0 +1,71 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r517699783
##
File path:
generator/src/main/java/org/apache/kafka/message/JsonConverterGenerator.java
##
@@ -380,8 +380,9 @@ private void generateVariableLengthT
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r517703078
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r517703625
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r517703953
##
File path:
raft/src/main/java/org/apache/kafka/snapshot/BatchedSnapshotWriter.java
##
@@ -0,0 +1,107 @@
+/*
+ * Licensed to the Apache Software Foundati
jsancio commented on a change in pull request #9512:
URL: https://github.com/apache/kafka/pull/9512#discussion_r517703078
##
File path: raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java
##
@@ -0,0 +1,36 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
abbccdda opened a new pull request #9558:
URL: https://github.com/apache/kafka/pull/9558
This PR will follow up
https://github.com/apache/kafka/commit/0814e4f645880a3c63102fc197c8912c63846ad5
to migrate the remaining RPCs which need forwarding:
- CreateAcls
- DeleteAcls
- Crea
abbccdda opened a new pull request #9559:
URL: https://github.com/apache/kafka/pull/9559
Hit an unfortunate merge conflict at the same time with
https://github.com/apache/kafka/commit/5df8457e05f6808145e90f5637d7f8a4aed548d9
### Committer Checklist (excluded from commit message)
-
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10181.
-
Resolution: Fixed
> Create Envelope RPC and redirection template for configuration change RPCs
>
abbccdda opened a new pull request #9560:
URL: https://github.com/apache/kafka/pull/9560
SSL trust store and key store paths update could no longer go through the
direct per broker update due to forwarding. We need to add a mechanism to
trigger the update through ZK notification.
##
[
https://issues.apache.org/jira/browse/KAFKA-10624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kowshik Prakasam reassigned KAFKA-10624:
Assignee: Kowshik Prakasam
> [Easy] FeatureZNodeStatus should use sealed trait in
kowshik opened a new pull request #9561:
URL: https://github.com/apache/kafka/pull/9561
In this PR, I've switched the `FeatureZNodeStatus` enum to be a sealed
trait. In Scala, we prefer sealed traits over Enumeration since the former
gives you exhaustiveness checking. With Scala enumeratio
kowshik commented on pull request #9561:
URL: https://github.com/apache/kafka/pull/9561#issuecomment-722097335
@junrao @abbccdda: this PR is ready for review.
This is an automated message from the Apache Git Service.
To resp
kowshik opened a new pull request #9562:
URL: https://github.com/apache/kafka/pull/9562
Fixed the param doc in `FinalizedFeatureChangeListener.initOrThrow` method.
The parameter `waitOnceForCacheUpdateMs` is expected to be > 0, but the doc was
incorrect.
-
kowshik commented on pull request #9561:
URL: https://github.com/apache/kafka/pull/9561#issuecomment-722113042
The build in CI is broken due to https://github.com/apache/kafka/pull/9559 .
I'll rebase on top of latest AK trunk, after that PR is merged.
-
kowshik commented on pull request #9562:
URL: https://github.com/apache/kafka/pull/9562#issuecomment-722119275
The build in CI is broken due to #9559 . I'll rebase on top of latest AK
trunk, after that PR is merged.
This is
kowshik edited a comment on pull request #9562:
URL: https://github.com/apache/kafka/pull/9562#issuecomment-722119275
The build in CI is broken due to absence of #9559. I'll rebase on top of
latest AK trunk, after that PR is merged.
kowshik edited a comment on pull request #9561:
URL: https://github.com/apache/kafka/pull/9561#issuecomment-722113042
The build in CI is broken due to absence of
https://github.com/apache/kafka/pull/9559. I'll rebase on top of latest AK
trunk, after that PR is merged.
---
chia7712 merged pull request #9559:
URL: https://github.com/apache/kafka/pull/9559
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
chia7712 commented on pull request #9562:
URL: https://github.com/apache/kafka/pull/9562#issuecomment-722124176
@kowshik I have merged #9559. Could you rebase PR to trigger QA again?
This is an automated message from the Apac
chia7712 commented on pull request #8826:
URL: https://github.com/apache/kafka/pull/8826#issuecomment-722128511
@junrao Thanks for your response. fixed.
This is an automated message from the Apache Git Service.
To respond to
kowshik commented on pull request #9562:
URL: https://github.com/apache/kafka/pull/9562#issuecomment-722130040
@chia7712 I've rebased now on top of #9559. Hopefully the build will go
green. Thank you for the review!
This is
Jason Gustafson created KAFKA-10684:
---
Summary: Avoid additional copies in envelope path when
transmitting over network
Key: KAFKA-10684
URL: https://issues.apache.org/jira/browse/KAFKA-10684
Projec
hachikuji opened a new pull request #9563:
URL: https://github.com/apache/kafka/pull/9563
This patch creates a new `SendBuilder` class which allows us to avoid
copying "bytes" types when transmitting an api message over the network. This
is used in `EnvelopeRequest` and `EnvelopeResponse`
Russell Sayers created KAFKA-10685:
--
Summary: --to-datetime passed to kafka-consumer-groups getting
interpreted as a timezone
Key: KAFKA-10685
URL: https://issues.apache.org/jira/browse/KAFKA-10685
P
[
https://issues.apache.org/jira/browse/KAFKA-10685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Russell Sayers updated KAFKA-10685:
---
Summary: --to-datetime passed to kafka-consumer-groups interpreting
microseconds wrong (was
[
https://issues.apache.org/jira/browse/KAFKA-10685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Russell Sayers updated KAFKA-10685:
---
Description:
f you pass more than 3 decimal places for the fractional seconds of the
dateti
[
https://issues.apache.org/jira/browse/KAFKA-10685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Russell Sayers updated KAFKA-10685:
---
Description:
If you pass more than 3 decimal places for the fractional seconds of the
datet
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226507#comment-17226507
]
Sarita commented on KAFKA-7500:
---
Was able to fix the bootstrap-server disconnect issue. Wen
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224651#comment-17224651
]
Sarita edited comment on KAFKA-7500 at 11/5/20, 6:11 AM:
-
Hi [~ry
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224651#comment-17224651
]
Sarita edited comment on KAFKA-7500 at 11/5/20, 6:12 AM:
-
Hi [~ry
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224651#comment-17224651
]
Sarita edited comment on KAFKA-7500 at 11/5/20, 6:13 AM:
-
Hi [~ry
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224651#comment-17224651
]
Sarita edited comment on KAFKA-7500 at 11/5/20, 6:13 AM:
-
Hi [~ry
[
https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17224651#comment-17224651
]
Sarita edited comment on KAFKA-7500 at 11/5/20, 6:24 AM:
-
Hi [~ry
chia7712 commented on a change in pull request #9563:
URL: https://github.com/apache/kafka/pull/9563#discussion_r517822478
##
File path: clients/src/main/resources/common/message/EnvelopeRequest.json
##
@@ -23,7 +23,7 @@
"fields": [
{ "name": "RequestData", "type": "byt
chia7712 commented on a change in pull request #9563:
URL: https://github.com/apache/kafka/pull/9563#discussion_r517824324
##
File path:
clients/src/main/java/org/apache/kafka/common/network/SendBuilder.java
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundati
chia7712 commented on pull request #9563:
URL: https://github.com/apache/kafka/pull/9563#issuecomment-722184706
Does this improvement work for other requests?
This is an automated message from the Apache Git Service.
To respo
1 - 100 of 103 matches
Mail list logo
