lbradstreet commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r413563167
##
File path:
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala
##
@@ -60,6 +61,7 @@ class ReplicaAlterLogDirsThreadTest {
lbradstreet commented on issue #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-618220519
I updated the PR to use Time everywhere that's required. Note that I did not
switch the fetcher tests to use MockTime as it appears they are timing
dependent and may depend on Abstra
lbradstreet edited a comment on issue #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-618220519
I updated the PR to pass Time everywhere that's required. Note that I did
not switch the fetcher tests to use MockTime as it appears they are timing
dependent and may depend o
dajac commented on a change in pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#discussion_r413546760
##
File path:
clients/src/test/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponseTest.java
##
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache
ijuma commented on issue #8513:
URL: https://github.com/apache/kafka/pull/8513#issuecomment-618224164
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
lbradstreet commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r413563167
##
File path:
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala
##
@@ -60,6 +61,7 @@ class ReplicaAlterLogDirsThreadTest {
ijuma commented on issue #8467:
URL: https://github.com/apache/kafka/pull/8467#issuecomment-618225193
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ijuma commented on issue #8464:
URL: https://github.com/apache/kafka/pull/8464#issuecomment-618226016
Unrelated failed flaky test:
>
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
-
ijuma commented on issue #8456:
URL: https://github.com/apache/kafka/pull/8456#issuecomment-618226721
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
ijuma commented on a change in pull request #8450:
URL: https://github.com/apache/kafka/pull/8450#discussion_r413572295
##
File path: build.gradle
##
@@ -1103,8 +1103,14 @@ project(':clients') {
}
compileJava.dependsOn 'processMessages'
+ compileJava {
+options.com
tombentley commented on issue #8417:
URL: https://github.com/apache/kafka/pull/8417#issuecomment-618227764
Thanks @ijuma
This is an automated message from the Apache Git Service.
To respond to the message, please log on to G
ijuma commented on a change in pull request #8449:
URL: https://github.com/apache/kafka/pull/8449#discussion_r413573833
##
File path:
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java
##
@@ -32,6 +32,7 @@
* using the default constructor and will the
leonardge commented on issue #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-618229704
Why is the CI failing?
This is an automated message from the Apache Git Service.
To respond to the message, please log
ijuma commented on issue #8427:
URL: https://github.com/apache/kafka/pull/8427#issuecomment-618230317
Thanks for the PR. Since this has potential compatibility implications, it
requires a KIP.
This is an automated message fr
[
https://issues.apache.org/jira/browse/KAFKA-9903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090355#comment-17090355
]
shilin Lu commented on KAFKA-9903:
--
[~guozhang] [~ijuma]
> kafka ShutdownableThread ju
ijuma commented on issue #8429:
URL: https://github.com/apache/kafka/pull/8429#issuecomment-618238203
Unrelated flaky test failure in 1 (out of 3) jobs:
>
kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete
---
stanislavkozlovski commented on issue #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-618264305
JDK 8 failed with
```
06:01:27 #
06:01:27 # There is insufficient memory for the Java Runtime Environment to
continue.
06:01:27 # Cannot create GC thread. Out of sy
leonardge commented on issue #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-618264854
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
leonardge removed a comment on issue #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-618264854
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618276927
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
zshuo commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618278914
Is there anything else I need to do before it gets merged?
This is an automated message from the Apache Git Service.
To res
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618280153
@zshuo No. I've taken a look at the change and it looks good. By commenting
`ok to test`, I triggered the Jenkins builds. If those builds pass, I'll merge
your PR
mimaison commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r413647728
##
File path: core/src/test/scala/unit/kafka/admin/DescribeConsumerGroupTest.scala
##
@@ -52,11 +51,25 @@ class DescribeConsumerGroupTest extends
Consumer
cadonna commented on issue #8532:
URL: https://github.com/apache/kafka/pull/8532#issuecomment-618292163
Streams system tests above are green.
This is an automated message from the Apache Git Service.
To respond to the messag
lrytz commented on a change in pull request #8429:
URL: https://github.com/apache/kafka/pull/8429#discussion_r413662887
##
File path: build.gradle
##
@@ -484,6 +484,12 @@ subprojects {
scalaCompileOptions.additionalParameters += ["-opt:l:inline"]
scalaCompileOptions.a
zshuo commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618311862
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618329701
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
cmccabe commented on a change in pull request #8527:
URL: https://github.com/apache/kafka/pull/8527#discussion_r413713907
##
File path:
core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala
##
@@ -1408,13 +1408,23 @@ class DynamicBrokerReconfigura
mimaison commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r413717848
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -1553,6 +1554,50 @@ class KafkaApisTest {
assertEquals(Errors.INVALID_RE
tombentley commented on a change in pull request #8449:
URL: https://github.com/apache/kafka/pull/8449#discussion_r413718361
##
File path:
clients/src/main/java/org/apache/kafka/server/policy/AlterConfigPolicy.java
##
@@ -32,6 +32,7 @@
* using the default constructor and wil
cmccabe commented on issue #8527:
URL: https://github.com/apache/kafka/pull/8527#issuecomment-618334410
For `ConfigCommandTest.scala`, we should keep the tests of the `--zookeeper`
command since that is still present in trunk.
The goal should be to remove unnecessary dependencies on
cmccabe commented on a change in pull request #8527:
URL: https://github.com/apache/kafka/pull/8527#discussion_r413718893
##
File path: core/src/test/scala/unit/kafka/admin/DeleteTopicTest.scala
##
@@ -227,8 +227,10 @@ class DeleteTopicTest extends ZooKeeperTestHarness {
}
cmccabe commented on a change in pull request #8527:
URL: https://github.com/apache/kafka/pull/8527#discussion_r413719892
##
File path:
core/src/test/scala/unit/kafka/admin/ReassignPartitionsCommandArgsTest.scala
##
@@ -255,7 +225,7 @@ class ReassignPartitionsCommandArgsTest {
cmccabe commented on a change in pull request #8527:
URL: https://github.com/apache/kafka/pull/8527#discussion_r413720950
##
File path:
core/src/test/scala/unit/kafka/admin/TopicCommandWithAdminClientTest.scala
##
@@ -293,13 +293,6 @@ class TopicCommandWithAdminClientTest exte
Bob Wen created KAFKA-9908:
--
Summary: Kafka client always trying "kinit -R" even the
ticketCache has been renewed by external
Key: KAFKA-9908
URL: https://issues.apache.org/jira/browse/KAFKA-9908
Project: Ka
cmccabe commented on issue #8527:
URL: https://github.com/apache/kafka/pull/8527#issuecomment-618337731
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
cmccabe commented on issue #8527:
URL: https://github.com/apache/kafka/pull/8527#issuecomment-618338178
Looks like the JDK8 build flaked.
```
11:00:07 Error occurred during initialization of VM
11:00:07 java.lang.OutOfMemoryError: unable to create new native thread
```
We've g
cmccabe edited a comment on issue #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-618341335
> For the scram credential related code piece, switched to using
--bootstrap-server even we don't support it yet.
We need to keep using --zookeeper in the SCRAM case since w
cmccabe commented on issue #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-618341335
> For the scram credential related code piece, switched to using
--bootstrap-server even we don't support it yet.
We need to keep using --zookeeper in the SCRAM case since we don't hav
cmccabe commented on issue #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-618342661
It looks like the places where we invoke `kafka-configs.sh` still need to be
converted over to use `--bootstrap-server`
cmccabe commented on issue #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-618343269
Same issue with `kafka-reassign-partitions.sh`. It also needs to be
converted to use `--bootstrap-server`.
This is an a
cmccabe commented on issue #8528:
URL: https://github.com/apache/kafka/pull/8528#issuecomment-618343631
There are a lot of whitespace-only changes in this PR that are kind of
confusing. Can you please do these in a separate PR or just drop them?
--
Gopikrishna created KAFKA-9909:
--
Summary: Kafka Streams : offset control to Streams API
Key: KAFKA-9909
URL: https://issues.apache.org/jira/browse/KAFKA-9909
Project: Kafka
Issue Type: Improveme
mimaison commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r413794118
##
File path: core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
##
@@ -84,6 +87,15 @@ object ConsumerGroupCommand extends Logging {
}
}
mimaison commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r413794118
##
File path: core/src/main/scala/kafka/admin/ConsumerGroupCommand.scala
##
@@ -84,6 +87,15 @@ object ConsumerGroupCommand extends Logging {
}
}
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618400831
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-61840
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ijuma commented on issue #8517:
URL: https://github.com/apache/kafka/pull/8517#issuecomment-618409553
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ijuma commented on issue #8537:
URL: https://github.com/apache/kafka/pull/8537#issuecomment-618412385
Thanks, I addressed the comment and I merged to trunk.
This is an automated message from the Apache Git Service.
To respond
ijuma commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r413826884
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir to log
ijuma commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r413826884
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir to log
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618418722
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
[
https://issues.apache.org/jira/browse/KAFKA-9907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-9907.
Resolution: Fixed
> Switch default build to Scala 2.13
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090649#comment-17090649
]
Lovro Pandžić commented on KAFKA-9603:
--
Sadly, I've been unable to reproduce the iss
ijuma opened a new pull request #8538:
URL: https://github.com/apache/kafka/pull/8538
The version of Zinc included with Gradle 6.4 includes a fix for the blocker
that was preventing us from passing `-release 8` to scalac.
Release notes for Gradle 6.4:
https://docs.gradle.org
ijuma commented on issue #8364:
URL: https://github.com/apache/kafka/pull/8364#issuecomment-618429581
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
ijuma commented on issue #8151:
URL: https://github.com/apache/kafka/pull/8151#issuecomment-618430121
@stanislavkozlovski any thoughts on the comments above?
This is an automated message from the Apache Git Service.
To respon
ijuma commented on issue #7231:
URL: https://github.com/apache/kafka/pull/7231#issuecomment-618430662
Looks like this has a conflict.
This is an automated message from the Apache Git Service.
To respond to the message, please
bbejeck commented on a change in pull request #8504:
URL: https://github.com/apache/kafka/pull/8504#discussion_r413860696
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
##
@@ -989,16 +994,18 @@ private void to(final TopicNameExt
bbejeck commented on issue #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-618447861
>Why that? Because such a topology would hit the bug, it could never be
deployed, and thus nobody can actually run such a topology? In fact, shouldn't
be "burn" and index even if a name
bbejeck commented on issue #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-618450970
@mjsax thanks for the review!
This is an automated message from the Apache Git Service.
To respond to the message, please
junrao commented on issue #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-618473781
@cmccabe : Does this look good to you? Thanks.
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-2419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090711#comment-17090711
]
Jun Rao commented on KAFKA-2419:
Sensor expiring is only used on the broker. For the clie
[
https://issues.apache.org/jira/browse/KAFKA-9603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090715#comment-17090715
]
Bruno Cadonna commented on KAFKA-9603:
--
[~lpandzic] Thank you for the information.
[
https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090718#comment-17090718
]
Patrick Szalapski commented on KAFKA-9747:
--
Yes, please at least give a WARN or
[
https://issues.apache.org/jira/browse/KAFKA-9747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090718#comment-17090718
]
Patrick Szalapski edited comment on KAFKA-9747 at 4/23/20, 4:03 PM:
---
abbccdda commented on a change in pull request #8486:
URL: https://github.com/apache/kafka/pull/8486#discussion_r413925987
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/EpochEndOffset.java
##
@@ -86,4 +84,9 @@ public boolean equals(Object o) {
publi
[
https://issues.apache.org/jira/browse/KAFKA-9652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17090732#comment-17090732
]
Agam Brahma commented on KAFKA-9652:
Not working on this right now, please go ahead.
[
https://issues.apache.org/jira/browse/KAFKA-9652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Agam Brahma reassigned KAFKA-9652:
--
Assignee: Ismael Juma (was: Agam Brahma)
> Throttle time metric needs to be updated for KIP-2
hachikuji commented on issue #8509:
URL: https://github.com/apache/kafka/pull/8509#issuecomment-618497996
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
hachikuji commented on issue #8454:
URL: https://github.com/apache/kafka/pull/8454#issuecomment-618505412
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618536956
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
ijuma commented on issue #8538:
URL: https://github.com/apache/kafka/pull/8538#issuecomment-618541154
1 flaky failure:
>
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
-
guozhangwang commented on issue #8326:
URL: https://github.com/apache/kafka/pull/8326#issuecomment-618541912
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on
ijuma commented on issue #8231:
URL: https://github.com/apache/kafka/pull/8231#issuecomment-618544406
@mumrah we have switched to 2.13 as the default and it has fatal warnings
enabled, so I think that's the better place to focus. It wasn't clear to me if
2.13 is catching all the unused war
ijuma edited a comment on issue #8231:
URL: https://github.com/apache/kafka/pull/8231#issuecomment-618544406
@mumrah we have switched to 2.13 as the default and enabled fatal warnings,
so I think that's the better place to focus. It wasn't clear to me if 2.13 is
catching all the unused war
rhauch commented on a change in pull request #8536:
URL: https://github.com/apache/kafka/pull/8536#discussion_r414006134
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java
##
@@ -341,7 +341,15 @@ private void che
rhauch commented on issue #8536:
URL: https://github.com/apache/kafka/pull/8536#issuecomment-618552614
Thanks, @kkonstantine. I've incorporated your suggestions.
This is an automated message from the Apache Git Service.
To re
leonardge commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r414012223
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1068,7 +1068,9 @@ class KafkaController(val config: KafkaConfig,
C0urante commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r414016126
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -263,17 +267,20 @@ public boolean startConnector(
cmccabe commented on issue #8489:
URL: https://github.com/apache/kafka/pull/8489#issuecomment-618573775
This looks reasonable. What testing have we done so far?
This is an automated message from the Apache Git Service.
To re
guozhangwang commented on a change in pull request #8445:
URL: https://github.com/apache/kafka/pull/8445#discussion_r414027883
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinatorTest.java
##
@@ -466,24 +477,193 @@ public void
te
junrao commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r414042238
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1068,7 +1068,12 @@ class KafkaController(val config: KafkaConfig,
va
bseenu commented on pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#issuecomment-618596724
@thspinto @ning2008wisc i am trying this , but i do not see the consumer
offsets being populated on the target side, my consumer group is not dead i am
polling for messages every 5
bseenu edited a comment on pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#issuecomment-618596724
@thspinto @ning2008wisc i am trying this , but i do not see the consumer
offsets being populated on the target side, my consumer group is not dead i am
polling for messages
[
https://issues.apache.org/jira/browse/KAFKA-9823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-9823.
--
Fix Version/s: 2.6.0
Resolution: Fixed
> Consumer should check equality of the generatio
abbccdda commented on pull request #8326:
URL: https://github.com/apache/kafka/pull/8326#issuecomment-618627112
Test only fails the flaky test:
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
Boyang Chen created KAFKA-9911:
--
Summary: Implement new producer fenced error
Key: KAFKA-9911
URL: https://issues.apache.org/jira/browse/KAFKA-9911
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9910:
--
Summary: Implement new transaction timed out error
Key: KAFKA-9910
URL: https://issues.apache.org/jira/browse/KAFKA-9910
Project: Kafka
Issue Type: Sub-task
ConcurrencyPractitioner commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-618639865
@vvcephei Thanks for all the help! It would've probably taken me quite a
while to get through all this by myself. I will update PR shortly. :)
---
cmccabe opened a new pull request #8539:
URL: https://github.com/apache/kafka/pull/8539
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
lbradstreet commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414100944
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir
lbradstreet commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414100944
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir
lbradstreet commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414101438
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir
lbradstreet commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414100944
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir
ijuma commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414106367
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir to log
ijuma commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414105901
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir to log
ijuma commented on a change in pull request #8467:
URL: https://github.com/apache/kafka/pull/8467#discussion_r414106806
##
File path: core/src/main/scala/kafka/log/LogManager.scala
##
@@ -1003,9 +1003,17 @@ class LogManager(logDirs: Seq[File],
/**
* Map of log dir to log
[
https://issues.apache.org/jira/browse/KAFKA-9844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9844.
Fix Version/s: 2.6.0
Resolution: Fixed
> Maximum number of members within a group is
Igor Baltiyskiy created KAFKA-9912:
--
Summary: Kafka deletes full log on startup written 30mins ago -
wrongly claims retention time 7d breach
Key: KAFKA-9912
URL: https://issues.apache.org/jira/browse/KAFKA-9912
1 - 100 of 163 matches
Mail list logo
