chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-650503360
> For comparison, 29 test failures in trunk
http://testing.confluent.io/confluent-kafka-system-test-results/?prefix=2020-06-25--001.1593132363--apache--trunk--3348fc49d/
It
C0urante commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r446490310
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -689,6 +692,10 @@ else if (!context.pausedPartition
C0urante commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r446490310
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -689,6 +692,10 @@ else if (!context.pausedPartition
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146776#comment-17146776
]
Sean Guo commented on KAFKA-10134:
--
We can try the patch next week to see whether this
guozhangwang commented on pull request #8925:
URL: https://github.com/apache/kafka/pull/8925#issuecomment-650487412
> Could we include the purpose of this PR in the title, such as "Integration
test shouldApplyUpdatesToStandbyStore fix:... "
SG
--
abbccdda commented on pull request #8925:
URL: https://github.com/apache/kafka/pull/8925#issuecomment-650486850
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650483907
backported to 2.6, 2.5, and 2.4. I ran the streams and client tests each
time, as well as systemTestLibs.
This i
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146758#comment-17146758
]
John Roesler commented on KAFKA-10173:
--
Ok, the fix is now backported all the way b
[
https://issues.apache.org/jira/browse/KAFKA-10207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146757#comment-17146757
]
Johnny Malizia commented on KAFKA-10207:
I didn't see where to assign this to me
Johnny-Malizia opened a new pull request #8936:
URL: https://github.com/apache/kafka/pull/8936
In some cases when a new log segment is rolled, the previous segment's
timeindex and offset index do not have the excess 0 bytes trimmed. This
results in a situation where the next load from
[
https://issues.apache.org/jira/browse/KAFKA-10207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Johnny Malizia updated KAFKA-10207:
---
Description:
[KIP-263|https://cwiki.apache.org/confluence/display/KAFKA/KIP-263%3A+Allow+bro
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146749#comment-17146749
]
John Roesler commented on KAFKA-10173:
--
Ok, I've just merged the fix ([https://gith
[
https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146747#comment-17146747
]
John Roesler commented on KAFKA-8630:
-
Hey, all, I inadvertently started a new ticket
[
https://issues.apache.org/jira/browse/KAFKA-8630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-8630:
---
Assignee: John Roesler
> Unit testing a streams processor with a WindowStore throws a
> Cla
vvcephei merged pull request #8905:
URL: https://github.com/apache/kafka/pull/8905
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
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650476597
Failures were unrelated:
```
kafka.api.PlaintextConsumerTest > testLowMaxFetchSizeForRequestAndPartition
FAILED
org.scalatest.exceptions.TestFailedException: Time
[
https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10185.
--
Resolution: Fixed
> Streams should log summarized restoration information at info level
>
[
https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146739#comment-17146739
]
John Roesler commented on KAFKA-10185:
--
Hey [~rhauch] ,
Sorry, I should have email
[
https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10185:
-
Fix Version/s: (was: 2.7.0)
2.5.1
2.6.0
> Streams shou
vvcephei commented on a change in pull request #8927:
URL: https://github.com/apache/kafka/pull/8927#discussion_r446473287
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Ap
vvcephei commented on pull request #8914:
URL: https://github.com/apache/kafka/pull/8914#issuecomment-650474359
Thanks for running the tests.
One test failed. I haven't looked to see if it's important:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.c
vvcephei commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r446472130
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractStateManager.java
##
@@ -0,0 +1,33 @@
+/*
+ * Licensed to the Apa
vvcephei commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r446471839
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java
##
@@ -103,8 +104,13 @@ public void init(final Proc
vvcephei commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r446471736
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java
##
@@ -124,18 +141,19 @@ public void before() {
showuon commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r446126644
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -125,35 +131,37 @@ public InternalTopicMan
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146724#comment-17146724
]
Neo Wu commented on KAFKA-10134:
something like this fix my issues, but i am not sure wh
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146723#comment-17146723
]
Neo Wu commented on KAFKA-10134:
maybe besides fetchablePartitions, it also should check
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146721#comment-17146721
]
Neo Wu commented on KAFKA-10134:
Hi, [~guozhang]
Thanks for quick update!
I reviewed
Johnny Malizia created KAFKA-10207:
--
Summary: Untrimmed Index files cause premature log segment
deletions on startup
Key: KAFKA-10207
URL: https://issues.apache.org/jira/browse/KAFKA-10207
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10189:
Labels: (was: core)
> Reset metric EventQueueTimeMs
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10189:
Labels: core (was: pull-request-available)
> Reset metric EventQueueTimeMs
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10189:
Component/s: core
> Reset metric EventQueueTimeMs
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146707#comment-17146707
]
Almog Gavra commented on KAFKA-10179:
-
[~ableegoldman] I confirmed locally that noth
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146706#comment-17146706
]
Guozhang Wang commented on KAFKA-10134:
---
I've provided a PR for trunk, but it shou
jeffkbkim opened a new pull request #8935:
URL: https://github.com/apache/kafka/pull/8935
*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.*
* https://issues.ap
guozhangwang commented on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-650464132
@hachikuji @ijuma
This is an automated message from the Apache Git Service.
To respond to the message, pleas
guozhangwang opened a new pull request #8934:
URL: https://github.com/apache/kafka/pull/8934
The intention of using poll(0) is to not block on rebalance but still return
some data; however, if there's no fetchable partitions then there's no point of
polling with 0ms. What's worse, with pol
guozhangwang commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446461812
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -258,34 +263,43 @@ private v
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650462969
Ok, @guozhangwang , This is my "final" iteration. I pulled the system tests
out, and I'll follow up with another PR later. This PR should be sufficient for
the basic purpose, tha
[
https://issues.apache.org/jira/browse/KAFKA-6453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Victoria Bialas resolved KAFKA-6453.
Resolution: Fixed
Fixed by James Galasyn in https://github.com/apache/kafka/pull/8920
> Re
ableegoldman closed pull request #6633:
URL: https://github.com/apache/kafka/pull/6633
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 closed pull request #7413:
URL: https://github.com/apache/kafka/pull/7413
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
[
https://issues.apache.org/jira/browse/KAFKA-10177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146681#comment-17146681
]
Sophie Blee-Goldman commented on KAFKA-10177:
-
I haven't personally looked i
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146678#comment-17146678
]
Guozhang Wang commented on KAFKA-10134:
---
[~seanguo] I think [~neowu0]'s brought up
[
https://issues.apache.org/jira/browse/KAFKA-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-10166.
-
Resolution: Fixed
> Excessive TaskCorruptedException seen in testing
> -
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reassigned KAFKA-10134:
-
Assignee: Guozhang Wang
> High CPU issue during rebalance in Kafka consumer after upgra
guozhangwang commented on pull request #8926:
URL: https://github.com/apache/kafka/pull/8926#issuecomment-650426719
Cherry-picked to 2.6 since it is a blocker, cc @rhauch
This is an automated message from the Apache Git Serv
guozhangwang merged pull request #8926:
URL: https://github.com/apache/kafka/pull/8926
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 a change in pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#discussion_r446431689
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
##
@@ -226,7 +227,7 @@ public StreamsMetada
satishbellapu commented on pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#issuecomment-650419736
+ @cmccabe @rajinisivaram for review.
This is an automated message from the Apache Git Service.
To respond t
ableegoldman commented on pull request #8925:
URL: https://github.com/apache/kafka/pull/8925#issuecomment-650414999
Is Jenkins linking to the wrong builds? When I try to see which tests failed
here it seems to bring me to the results for two completely different PRs.
Really dropping
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650413094
I will follow up shortly to extract the system tests to a separate PR, since
we're having trouble running the tests at all right now, and we wouldn't know
if they are even more b
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650412771
Hey @guozhangwang , you might want to take a look at that last fix. The
duck-typing code was producing an OOME some times, when it would just interpret
a random integer out of th
ableegoldman commented on a change in pull request #8927:
URL: https://github.com/apache/kafka/pull/8927#discussion_r446418844
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextUtils.java
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to th
vvcephei commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446409619
##
File path: build.gradle
##
@@ -97,7 +97,7 @@ ext {
buildVersionFileName = "kafka-version.properties"
defaultMaxHeapSize = "2g"
- defaultJvmArgs
ableegoldman commented on a change in pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#discussion_r446408964
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
##
@@ -226,7 +227,7 @@ public StreamsMetada
abbccdda commented on a change in pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#discussion_r446404393
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
##
@@ -50,7 +51,7 @@
private final HostInf
ryannedolan commented on pull request #8930:
URL: https://github.com/apache/kafka/pull/8930#issuecomment-650389551
@cgetzen the larger change would be worth it IMO. I think a KIP is the right
way forward. Happy to help, but you should be able to get permission to create
a KIP yourself. Mig
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650387794
Ah, that heap space thing was legit. Fix coming...
This is an automated message from the Apache Git Service.
To r
abbccdda commented on pull request #8926:
URL: https://github.com/apache/kafka/pull/8926#issuecomment-650385489
```12:23:50 FAILURE: Build failed with an exception.
12:23:50
12:23:50 * What went wrong:
12:23:50 Execution failed for task ':streams:unitTest'.
12:23:50 > Process 'G
lct45 commented on pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#issuecomment-650384491
Failed connect tests on JDC 14
org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest.testReplication
org.apache.kafka.connect.integration.BlockingConnectorTest.testB
ableegoldman commented on pull request #8926:
URL: https://github.com/apache/kafka/pull/8926#issuecomment-650382721
Java 8 and 14 builds passed, Java 11 build failed with...zero failures?
This is an automated message from the
cgetzen edited a comment on pull request #8930:
URL: https://github.com/apache/kafka/pull/8930#issuecomment-650381294
Hi @ryannedolan, wondering if you could spare a little guidance.
I created `offset-syncs.topic.override` variable with a default of `null`.
What I would have loved to
[
https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146612#comment-17146612
]
Leah Thomas commented on KAFKA-9509:
Failed again:
h3. Stacktrace
java.lang.RuntimeE
cgetzen commented on pull request #8930:
URL: https://github.com/apache/kafka/pull/8930#issuecomment-650381294
Hi @ryannedolan, wondering if you could spare a little guidance.
I created `offset-syncs.topic.override` variable with a default of `null`.
What I would have loved to do is
gharris1727 commented on a change in pull request #8910:
URL: https://github.com/apache/kafka/pull/8910#discussion_r446379953
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java
##
@@ -689,6 +692,10 @@ else if (!context.pausedPartit
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10181:
Fix Version/s: 2.7.0
> AlterConfig/IncrementalAlterConfig should go to controller
> --
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10181:
Component/s: admin
> AlterConfig/IncrementalAlterConfig should go to controller
>
[
https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146596#comment-17146596
]
João Oliveirinha commented on KAFKA-9693:
-
[~junrao] thanks for the analysis and
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650355203
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650354756
Hmm. Still saw the OOME in
https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/3134/
This is an automated mess
guozhangwang commented on pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#issuecomment-650354464
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
vvcephei commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446365992
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -258,34 +263,43 @@ private void
vvcephei commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446364196
##
File path:
streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to t
vvcephei commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446364364
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedKeyValueBufferChangelogDeserializationHelper.java
##
@@ -0,0 +1,11
vvcephei commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446363798
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueBuffer.java
##
@@ -361,26 +366,20 @@ private void
guozhangwang commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446343541
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -189,8 +192,8 @@ def test_upgrade_downgrade_brokers(self, from_version,
to_v
ijuma commented on pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#issuecomment-650319283
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Git
ableegoldman commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-650316087
The system tests I'm triggering keep failing, but not because of this PR.
Not sure what's going on :/
But I'll try again:
https://jenkins.confluent.io/job/system-test-
efeg commented on a change in pull request #8579:
URL: https://github.com/apache/kafka/pull/8579#discussion_r446327952
##
File path: core/src/main/scala/kafka/server/AbstractFetcherThread.scala
##
@@ -382,6 +382,12 @@ abstract class AbstractFetcherThread(name: String,
omkreddy closed pull request #8932:
URL: https://github.com/apache/kafka/pull/8932
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
andrewchoi5 commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r446318540
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,16 @@ class Partition(val topicPartition: TopicPartition,
add
ableegoldman commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r446316588
##
File path:
streams/src/test/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStoreTest.java
##
@@ -124,18 +141,19 @@ public void before
junrao commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r446316668
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,16 @@ class Partition(val topicPartition: TopicPartition,
addingRe
[
https://issues.apache.org/jira/browse/KAFKA-9693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146527#comment-17146527
]
Jun Rao commented on KAFKA-9693:
[~joliveirinha]: Thanks for the analysis. To trigger the
ijuma commented on pull request #8931:
URL: https://github.com/apache/kafka/pull/8931#issuecomment-650297987
One job passed, two had a single unrelated test failure.
This is an automated message from the Apache Git Service.
T
ijuma merged pull request #8931:
URL: https://github.com/apache/kafka/pull/8931
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-10166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146501#comment-17146501
]
Sophie Blee-Goldman commented on KAFKA-10166:
-
Thanks for the detailed analy
andrewchoi5 commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r446309532
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,16 @@ class Partition(val topicPartition: TopicPartition,
add
ableegoldman commented on a change in pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#discussion_r446308395
##
File path: gradle/spotbugs-exclude.xml
##
@@ -348,14 +348,11 @@ For a detailed description of spotbugs bug categories,
see https://spotbugs.read
junrao commented on a change in pull request #8479:
URL: https://github.com/apache/kafka/pull/8479#discussion_r446306280
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -499,7 +500,16 @@ class Partition(val topicPartition: TopicPartition,
addingRe
vvcephei commented on pull request #8926:
URL: https://github.com/apache/kafka/pull/8926#issuecomment-650288339
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8926:
URL: https://github.com/apache/kafka/pull/8926#issuecomment-650288465
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
abbccdda commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-650275504
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
abbccdda commented on pull request #8914:
URL: https://github.com/apache/kafka/pull/8914#issuecomment-650275130
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#issuecomment-650270782
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
vvcephei commented on pull request #8929:
URL: https://github.com/apache/kafka/pull/8929#issuecomment-650271007
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
vvcephei commented on a change in pull request #8905:
URL: https://github.com/apache/kafka/pull/8905#discussion_r446265559
##
File path: build.gradle
##
@@ -97,7 +97,7 @@ ext {
buildVersionFileName = "kafka-version.properties"
defaultMaxHeapSize = "2g"
- defaultJvmArgs
[
https://issues.apache.org/jira/browse/KAFKA-10206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17146444#comment-17146444
]
Tom Bentley commented on KAFKA-10206:
-
I think the broker needs some alternative to
Tom Bentley created KAFKA-10206:
---
Summary: Admin can transiently return incorrect results about
topics
Key: KAFKA-10206
URL: https://issues.apache.org/jira/browse/KAFKA-10206
Project: Kafka
Is
1 - 100 of 160 matches
Mail list logo