dajac commented on a change in pull request #9506:
URL: https://github.com/apache/kafka/pull/9506#discussion_r512458078
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java
##
@@ -46,6 +46,30 @@
private final TopicParti
kkonstantine commented on a change in pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#discussion_r512487036
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -260,7 +259,7 @@ pr
kkonstantine commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-717080224
Also, please try to rebase on top of the latest trunk changes to see if a
build can be triggered in that case.
-
[
https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221254#comment-17221254
]
Filippo Machi commented on KAFKA-10645:
---
Hello [~mjsax] ,
thanks for your reply. T
chia7712 opened a new pull request #9509:
URL: https://github.com/apache/kafka/pull/9509
I believe that is a kind of typo since it is not consistent to other related
metrics name.
1. io-wait-time-ns-avg
1. io-time-ns-avg
1. io-wait-ratio
1. io-ratio
### Committer Chec
Valentina Glagoleva created KAFKA-10649:
---
Summary: CPU increase after the upgrade to Kafka 2.5
Key: KAFKA-10649
URL: https://issues.apache.org/jira/browse/KAFKA-10649
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Valentina Glagoleva updated KAFKA-10649:
Description:
After an upgrade from Kafka 2.2.1 to Kafka 2.5.1 we noticed, that som
chia7712 commented on pull request #9162:
URL: https://github.com/apache/kafka/pull/9162#issuecomment-717116228
```
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta
```
it is traced by https://issues.apache.org/jira/browse/KAFKA-
chia7712 merged pull request #9162:
URL: https://github.com/apache/kafka/pull/9162
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-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Valentina Glagoleva updated KAFKA-10649:
Description:
After an upgrade from Kafka 2.2.1 to Kafka 2.5.1 we noticed, that som
showuon commented on pull request #9507:
URL: https://github.com/apache/kafka/pull/9507#issuecomment-717119800
@chia7712 , thanks for your reminder. I've removed all the unnecessary
parameters (BOOTSTRAP_SERVERS_CONFIG and APPLICATION_ID_CONFIG) from the tests
which are using TopologyTestD
[
https://issues.apache.org/jira/browse/KAFKA-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Valentina Glagoleva updated KAFKA-10649:
Description:
After an upgrade from Kafka 2.2.1 to Kafka 2.5.1 we noticed, that som
[
https://issues.apache.org/jira/browse/KAFKA-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Valentina Glagoleva updated KAFKA-10649:
Description:
After an upgrade from Kafka 2.2.1 to Kafka 2.5.1 we noticed, that som
[
https://issues.apache.org/jira/browse/KAFKA-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Valentina Glagoleva updated KAFKA-10649:
Description:
After an upgrade from Kafka 2.2.1 to Kafka 2.5.1 we noticed, that som
dajac commented on pull request #9506:
URL: https://github.com/apache/kafka/pull/9506#issuecomment-717132358
@hachikuji @chia7712 Thanks for your review! Merging to trunk and 2.7.
This is an automated message from the Apache
dajac merged pull request #9506:
URL: https://github.com/apache/kafka/pull/9506
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-10647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-10647.
-
Resolution: Fixed
> Only serialize owned partition when consumer protocol version >= 0
> --
chia7712 commented on a change in pull request #9505:
URL: https://github.com/apache/kafka/pull/9505#discussion_r512566562
##
File path: clients/src/main/resources/common/message/FetchSnapshotRequest.json
##
@@ -0,0 +1,46 @@
+// Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-10649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221296#comment-17221296
]
Ismael Juma commented on KAFKA-10649:
-
Thanks for the report. This is likely KAFKA-9
dajac commented on pull request #9509:
URL: https://github.com/apache/kafka/pull/9509#issuecomment-717165385
@chia7712 Thanks for the PR. Renaming it may break monitoring of existing
users. As metrics are part of the public API, we may need a KIP to fix this...
---
[
https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221328#comment-17221328
]
Rajini Sivaram commented on KAFKA-7987:
---
[~junrao] This is still an open issue for
[
https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram updated KAFKA-7987:
--
Issue Type: Bug (was: Improvement)
Priority: Critical (was: Major)
> a broker's ZK sess
[
https://issues.apache.org/jira/browse/KAFKA-8124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221366#comment-17221366
]
Yu Wang commented on KAFKA-8124:
+1 spark2.3.2 with kafka2.0
> Beginning offset is after
chia7712 commented on pull request #9509:
URL: https://github.com/apache/kafka/pull/9509#issuecomment-717207173
@dajac thanks for reminder. I don't think this patch is worth doing that
effort. close it.
This is an automated
chia7712 closed pull request #9509:
URL: https://github.com/apache/kafka/pull/9509
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 #9469:
URL: https://github.com/apache/kafka/pull/9469#issuecomment-717207972
@ijuma Thanks for your comment. close it due to the bad refactor :(
This is an automated message from the Apache
chia7712 closed pull request #9469:
URL: https://github.com/apache/kafka/pull/9469
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 #9169:
URL: https://github.com/apache/kafka/pull/9169#issuecomment-717211456
@ijuma Does it need a KIP to resolve naming conflict in metrics? Although
I'm wonder whether is there a use case using this conflicted name.
chia7712 closed pull request #9283:
URL: https://github.com/apache/kafka/pull/9283
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 #9283:
URL: https://github.com/apache/kafka/pull/9283#issuecomment-717212130
As it may break metrics compatibility, I'm going to close it.
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/KAFKA-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-9697:
-
Assignee: (was: Chia-Ping Tsai)
> ControlPlaneNetworkProcessorAvgIdlePercent is alwa
[
https://issues.apache.org/jira/browse/KAFKA-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-9697:
--
Labels: need-kip (was: )
> ControlPlaneNetworkProcessorAvgIdlePercent is always NaN
>
[
https://issues.apache.org/jira/browse/KAFKA-9697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221385#comment-17221385
]
Chia-Ping Tsai commented on KAFKA-9697:
---
the patch may break metrics so KIP is requ
chia7712 closed pull request #8837:
URL: https://github.com/apache/kafka/pull/8837
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 closed pull request #8806:
URL: https://github.com/apache/kafka/pull/8806
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-10125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10125.
Resolution: Won't Fix
> The partition which is removing should be considered to be under r
[
https://issues.apache.org/jira/browse/KAFKA-10108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-10108.
Resolution: Won't Fix
> The cached configs of SslFactory should be updated only if the ssl
showuon commented on pull request #9507:
URL: https://github.com/apache/kafka/pull/9507#issuecomment-717223593
tests/Build/JDK 8: Pass
tests/Build/JDK 15: unrelated to my change
failed -
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosB
rondagostino opened a new pull request #9510:
URL: https://github.com/apache/kafka/pull/9510
Note that I had to remove `"mapKey": true` from `FeatureLevelRecord.json`
because with it I was seeing this stack trace during the build:
```
Exception in thread "main" java.lang.RuntimeEx
rondagostino closed pull request #9510:
URL: https://github.com/apache/kafka/pull/9510
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
brbrown25 commented on pull request #9057:
URL: https://github.com/apache/kafka/pull/9057#issuecomment-717322569
- [ ] update with latest master
- [ ] implement nested field support
- [ ] implement salt support
This is
Viktor Somogyi-Vass created KAFKA-10650:
---
Summary: Use Murmur3 hashing instead of MD5 in SkimpyOffsetMap
Key: KAFKA-10650
URL: https://issues.apache.org/jira/browse/KAFKA-10650
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viktor Somogyi-Vass updated KAFKA-10650:
Description:
The usage of MD5 has been uncovered during testing Kafka for FIPS (Fe
joshuagrisham commented on pull request #9492:
URL: https://github.com/apache/kafka/pull/9492#issuecomment-717335784
Yeah unfortunately some of the downstream the checks are still failing, it
seems to be related to this issue
https://issues.apache.org/jira/browse/KAFKA-10017
But all tes
[
https://issues.apache.org/jira/browse/KAFKA-10637?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221527#comment-17221527
]
Chia-Ping Tsai commented on KAFKA-10637:
[~katiforis] Thanks for your report. Co
brbrown25 edited a comment on pull request #9057:
URL: https://github.com/apache/kafka/pull/9057#issuecomment-717322569
- [x] update with latest master
- [ ] implement nested field support
- [ ] implement salt support
T
hachikuji commented on a change in pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#discussion_r512847195
##
File path: raft/src/main/java/org/apache/kafka/raft/internals/BatchBuilder.java
##
@@ -0,0 +1,231 @@
+/*
+ * Licensed to the Apache Software Foundation
bbejeck opened a new pull request #9511:
URL: https://github.com/apache/kafka/pull/9511
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
bbejeck commented on pull request #9511:
URL: https://github.com/apache/kafka/pull/9511#issuecomment-717387337
@kowshik here's the text we discussed offline yesterday for the upgrade
section.
This is an automated message fro
bbejeck commented on pull request #9511:
URL: https://github.com/apache/kafka/pull/9511#issuecomment-717387683
Once merged I'll cherry-pick this to 2.7
This is an automated message from the Apache Git Service.
To respond to t
jsancio opened a new pull request #9512:
URL: https://github.com/apache/kafka/pull/9512
This PR depends on https://github.com/apache/kafka/pull/9505. I will rebase
this PR once https://github.com/apache/kafka/pull/9505 has been merged.
This PR adds support for generating snapshot for
apovzner commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r512887499
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -697,6 +714,31 @@ private[kafka] class Acceptor(val endPoint: EndPoint,
i
apovzner commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r512888360
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -526,10 +527,14 @@ private[kafka] abstract class
AbstractServerThread(connectionQ
apovzner commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r512887499
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -697,6 +714,31 @@ private[kafka] class Acceptor(val endPoint: EndPoint,
i
[
https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221610#comment-17221610
]
Bill Bejeck commented on KAFKA-10638:
-
Hey [~vvcephei] I appreciate you wanting to g
[
https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10638:
Fix Version/s: (was: 2.7.0)
2.7.1
2.8.0
> QueryableState
[
https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221610#comment-17221610
]
Bill Bejeck edited comment on KAFKA-10638 at 10/27/20, 5:48 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10638:
Priority: Major (was: Blocker)
> QueryableStateIntegrationTest fails due to stricter store checki
guozhangwang commented on pull request #9418:
URL: https://github.com/apache/kafka/pull/9418#issuecomment-717420938
LGTM.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
lizthegrey commented on pull request #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-717421301
Honeycomb doesn't directly have an interest in this as we use Confluent's
packages, but we do run Confluent's Kafka distro on ARM64 (successfully).
---
[
https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221624#comment-17221624
]
Jun Rao commented on KAFKA-7987:
[~rsivaram], yes, I think this issue still exists on all
kkonstantine commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-717433838
After writing another test, I confirmed my impression after first reading
the code. So, this fix would help if all the lost workers joined after leaving
the group at about th
apovzner commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r512928815
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1207,14 +1286,26 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metr
bbejeck commented on pull request #9511:
URL: https://github.com/apache/kafka/pull/9511#issuecomment-717447946
only HTML so merging
This is an automated message from the Apache Git Service.
To respond to the message, please l
bbejeck merged pull request #9511:
URL: https://github.com/apache/kafka/pull/9511
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 #9511:
URL: https://github.com/apache/kafka/pull/9511#issuecomment-717449278
Merged #9511 into trunk
This is an automated message from the Apache Git Service.
To respond to the message, pleas
ramesh-muthusamy commented on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-717450100
@kkonstantine this is a good scenario, let me test and see it is already
captured. Thanks for test case.
--
ramesh-muthusamy commented on a change in pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#discussion_r512938005
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -577,15 +595,14
ramesh-muthusamy commented on a change in pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#discussion_r512938623
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -445,16 +444,34
bbejeck commented on pull request #9511:
URL: https://github.com/apache/kafka/pull/9511#issuecomment-717454236
cherry-picked to 2.7
This is an automated message from the Apache Git Service.
To respond to the message, please l
ramesh-muthusamy edited a comment on pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#issuecomment-717450100
@kkonstantine this is a good scenario, let me test and see if
it is already captured. Thanks for test case.
-
ramesh-muthusamy commented on a change in pull request #9319:
URL: https://github.com/apache/kafka/pull/9319#discussion_r512945677
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java
##
@@ -577,15 +596,14
apovzner commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r512951535
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1246,7 +1337,57 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metri
[
https://issues.apache.org/jira/browse/KAFKA-10648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10648:
Labels: kip (was: )
> Add Prefix Scan support to State Stores
> -
[
https://issues.apache.org/jira/browse/KAFKA-10648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10648:
Component/s: streams
> Add Prefix Scan support to State Stores
> -
hachikuji merged pull request #9418:
URL: https://github.com/apache/kafka/pull/9418
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/KAFKA-10601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10601.
-
Resolution: Fixed
> Add linger semantics to raft
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221678#comment-17221678
]
Matthias J. Sax commented on KAFKA-10645:
-
Well, I would have assumed that your
hachikuji commented on a change in pull request #9382:
URL: https://github.com/apache/kafka/pull/9382#discussion_r512370043
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1388,6 +1390,7 @@ class Log(@volatile private var _dir: File,
var validBytesCount = 0
[
https://issues.apache.org/jira/browse/KAFKA-10645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221709#comment-17221709
]
Filippo Machi commented on KAFKA-10645:
---
My input data doesn´t have headers.
I am
[
https://issues.apache.org/jira/browse/KAFKA-10297?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10297:
Fix Version/s: (was: 2.7.0)
> Don't use deprecated producer config `retries`
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-9497:
---
Fix Version/s: (was: 2.7.0)
> Brokers start up even if SASL provider is not loaded and throw NPE
[
https://issues.apache.org/jira/browse/KAFKA-10370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10370:
Fix Version/s: (was: 2.7.0)
> WorkerSinkTask: IllegalStateException cased by consumer.seek(tp,
[
https://issues.apache.org/jira/browse/KAFKA-10378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-10378:
Fix Version/s: (was: 2.6.1)
(was: 2.7.0)
> issue when create producer u
mjsax opened a new pull request #9513:
URL: https://github.com/apache/kafka/pull/9513
Headers are not allowed to be `null`, and thus the code does not check for
`null` headers. However, we don't have proper guards in place and had NPE in
the past if a header was `null`. This PR adds additi
[
https://issues.apache.org/jira/browse/KAFKA-7987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221756#comment-17221756
]
Rajini Sivaram commented on KAFKA-7987:
---
[~junrao]Thank you! I will follow up on th
rajinisivaram commented on pull request #7751:
URL: https://github.com/apache/kafka/pull/7751#issuecomment-717541120
@parafiend Will you be updating the PR to address the review comments from
@junrao ? As mentioned in the JIRA, this issue also affects the ZooKeeper
client used by authorize
[
https://issues.apache.org/jira/browse/KAFKA-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17221813#comment-17221813
]
Guozhang Wang commented on KAFKA-8803:
--
[~pdeole] I was OOO and just saw your messag
A. Sophie Blee-Goldman created KAFKA-10651:
--
Summary: Assignor reports offsets from uninitialized task
Key: KAFKA-10651
URL: https://issues.apache.org/jira/browse/KAFKA-10651
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-10651:
--
Assignee: A. Sophie Blee-Goldman
> Assignor reports offsets from unin
bbejeck opened a new pull request #9514:
URL: https://github.com/apache/kafka/pull/9514
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing s
bbejeck commented on pull request #9514:
URL: https://github.com/apache/kafka/pull/9514#issuecomment-717602172
Thanks @mjsax
This is an automated message from the Apache Git Service.
To respond to the message, please log on
bbejeck commented on pull request #9514:
URL: https://github.com/apache/kafka/pull/9514#issuecomment-717602293
only HTML, merging now
This is an automated message from the Apache Git Service.
To respond to the message, please
bbejeck merged pull request #9514:
URL: https://github.com/apache/kafka/pull/9514
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
mjsax commented on a change in pull request #9498:
URL: https://github.com/apache/kafka/pull/9498#discussion_r513093711
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -1396,5 +1
hachikuji merged pull request #9503:
URL: https://github.com/apache/kafka/pull/9503
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to
[
https://issues.apache.org/jira/browse/KAFKA-10644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10644.
-
Resolution: Fixed
> Fix VotedToUnattached test error
>
rodesai commented on a change in pull request #9498:
URL: https://github.com/apache/kafka/pull/9498#discussion_r513095994
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -1396,5
rodesai commented on a change in pull request #9498:
URL: https://github.com/apache/kafka/pull/9498#discussion_r513100855
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
##
@@ -1396,5
[
https://issues.apache.org/jira/browse/KAFKA-10651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-10651:
---
Description:
In KIP-441, the new HA assignor makes an informed decision abou
1 - 100 of 109 matches
Mail list logo
