highluck commented on a change in pull request #9105:
URL: https://github.com/apache/kafka/pull/9105#discussion_r464215307
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -197,8 +197,8 @@ synchronized boolean lock(fina
chia7712 commented on a change in pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#discussion_r464216698
##
File path:
clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java
##
@@ -228,6 +228,13 @@ public Password getPassword(String key) {
highluck commented on a change in pull request #9105:
URL: https://github.com/apache/kafka/pull/9105#discussion_r464215307
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -197,8 +197,8 @@ synchronized boolean lock(fina
kowshik commented on a change in pull request #9110:
URL: https://github.com/apache/kafka/pull/9110#discussion_r464213840
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2227,13 +2210,16 @@ class Log(@volatile private var _dir: File,
* @param segments The log s
chia7712 commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-667819033
@guozhangwang thanks for reviews
> One (very) minor thing is that, may also be overridden when passing into
the coordinator object, i.e. the value read from ConsumerConfig
abbccdda commented on pull request #9096:
URL: https://github.com/apache/kafka/pull/9096#issuecomment-667819088
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
showuon commented on pull request #9096:
URL: https://github.com/apache/kafka/pull/9096#issuecomment-667784086
Thanks @ableegoldman . I've updated based on your suggestion. Thanks.
This is an automated message from the Apache
guozhangwang commented on pull request #9102:
URL: https://github.com/apache/kafka/pull/9102#issuecomment-667734629
This change makes sense to me, thanks @chia7712
One (very) minor thing is that, `enableAutoCommit` may also be overridden
when passing into the coordinator object, i.e
RamanVerma commented on pull request #9112:
URL: https://github.com/apache/kafka/pull/9112#issuecomment-667719404
cc @hachikuji
Not sure why I am not able to add anyone as a reviewer to the PR. I am not
getting the add reviewers/recommended reviewers options.
-
RamanVerma commented on pull request #9112:
URL: https://github.com/apache/kafka/pull/9112#issuecomment-667719141
Ran `./gradlew core:test` locally. All tests passed.
This is an automated message from the Apache Git Service.
RamanVerma opened a new pull request #9112:
URL: https://github.com/apache/kafka/pull/9112
MetadataCache#getPartitionMetadata returns an error when the topic's leader
Id
is present at MetadataCache but listener endpoint is not present for this
leader.
For older version, LEADER_NOT_AV
[
https://issues.apache.org/jira/browse/KAFKA-10316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169607#comment-17169607
]
John Thomas commented on KAFKA-10316:
-
Ah, I was just reading the KIP documentations
[
https://issues.apache.org/jira/browse/KAFKA-10303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez resolved KAFKA-10303.
-
Resolution: Incomplete
> kafka producer says connect failed in cluster mode
> --
dhruvilshah3 commented on a change in pull request #9110:
URL: https://github.com/apache/kafka/pull/9110#discussion_r464100823
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -2227,14 +2210,17 @@ class Log(@volatile private var _dir: File,
* @param segments The
ijuma closed pull request #1417:
URL: https://github.com/apache/kafka/pull/1417
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
ijuma commented on pull request #1417:
URL: https://github.com/apache/kafka/pull/1417#issuecomment-667686994
Superseded by #8399.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ijuma commented on pull request #8399:
URL: https://github.com/apache/kafka/pull/8399#issuecomment-667686748
@soenkeliebau did you file the JIRA @junrao mentioned above? It would be
good to reference it here.
This is an auto
17 matches
Mail list logo