[
https://issues.apache.org/jira/browse/KAFKA-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153320#comment-17153320
]
Tom Bentley commented on KAFKA-10245:
-
This is essentially a dupe of https://issues.
[
https://issues.apache.org/jira/browse/KAFKA-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tom Bentley resolved KAFKA-10245.
-
Resolution: Duplicate
> Using vulnerable log4j version
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-9482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153322#comment-17153322
]
Aljoscha Pörtner commented on KAFKA-9482:
-
Maybe our problem is related to this.
tombentley commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655357176
@rajinisivaram @omkreddy please could you review or suggest another
committer for review?
This is an automated
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153365#comment-17153365
]
Di Campo commented on KAFKA-4273:
-
Just tried it, and WindowStoreIterator.remove is an un
rajinisivaram commented on pull request #8979:
URL: https://github.com/apache/kafka/pull/8979#issuecomment-655384902
@ijuma @hachikuji @edenhill Thanks for the responses. I will follow up on
KIP-392 discussion thread and update the PR.
-
[
https://issues.apache.org/jira/browse/KAFKA-4273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153365#comment-17153365
]
Di Campo edited comment on KAFKA-4273 at 7/8/20, 8:56 AM:
--
Just
akatona84 opened a new pull request #8992:
URL: https://github.com/apache/kafka/pull/8992
*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
akatona84 commented on pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#issuecomment-655458870
Hi @ijuma , I've encountered a test failure here which caused unexpected
threads in the following tests `@Before` phase.
This fixes the issue in case failure happen, only that
akatona84 edited a comment on pull request #8992:
URL: https://github.com/apache/kafka/pull/8992#issuecomment-655458870
Hi @ijuma , I've encountered a test failure here which caused unexpected
threads in the following tests `@Before` phase.
This fixes the issue in case failure happens, o
omkreddy edited a comment on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-655468333
@tombentley @showuon Can you help me to understand where are we calling
`DescribeConfigsRequestData.setConfigurationKeys()` in AdminClient? looks like
`ConfigurationKeys`
omkreddy commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-655468333
@tombentley @showuon Can you help me to understand where are we calling
`DescribeConfigsRequestData.setConfigurationKeys()` in AdminClient? looks like
we are always setting to n
sasukerui commented on pull request #8742:
URL: https://github.com/apache/kafka/pull/8742#issuecomment-655474005
> @sasukerui Can you please change the PR to target `master`?
ok,l see
This is an automated message from
rajinisivaram commented on a change in pull request #8986:
URL: https://github.com/apache/kafka/pull/8986#discussion_r451498688
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -460,15 +463,21 @@ boolean joinGroupIf
showuon commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-655510801
@omkreddy , I can take a look tomorrow ( my time). Thanks.
This is an automated message from the Apache Git Servic
tombentley commented on pull request #8966:
URL: https://github.com/apache/kafka/pull/8966#issuecomment-655533627
@omkreddy that is... an excellent question.
* In `HEAD` the only place it's set to non-null is in `RequestResponseTest`
* In 9a4f00f78b (i.e. just before the change to
[
https://issues.apache.org/jira/browse/KAFKA-8794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjin Lee resolved KAFKA-8794.
Resolution: Duplicate
Duplication of KAFKA-10120.
> Deprecate DescribeLogDirsResponse.[LogDirInfo,
dongjinleekr closed pull request #7204:
URL: https://github.com/apache/kafka/pull/7204
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
vvcephei commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-64900
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 #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-65002
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 #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-65206
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
omkreddy commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-65622
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
dajac commented on pull request #8985:
URL: https://github.com/apache/kafka/pull/8985#issuecomment-655567477
Jenkins looks good. There were one unrelated failed test during the JDK 14
and Scala 2.13 run.
This is an automated
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153667#comment-17153667
]
John Roesler commented on KAFKA-10226:
--
Sounds good :)
> KStream without SASL info
vvcephei opened a new pull request #8993:
URL: https://github.com/apache/kafka/pull/8993
Replaces the previous upgrade test's trivial Streams app
with the commonly used SmokeTest, exercising many more
features. Also adjust the test matrix to test upgrading
from each released version
omkreddy commented on a change in pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#discussion_r451626581
##
File path: core/src/test/scala/unit/kafka/admin/AclCommandTest.scala
##
@@ -161,10 +193,34 @@ class AclCommandTest extends ZooKeeperTestHarness with
Lo
vvcephei commented on a change in pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#discussion_r451634562
##
File path: build.gradle
##
@@ -1508,6 +1508,18 @@ project(':streams:upgrade-system-tests-24') {
}
}
+project(':streams:upgrade-system-tests-25') {
vvcephei commented on pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#issuecomment-655605721
Started the new test:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4015/
And all streams tests:
https://jenkins.confluent.io/job/system-test-kafka-branch-
tombentley commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655617244
@omkreddy done
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-9144:
---
Fix Version/s: 2.3.2
2.2.3
> Early expiration of producer state can cause
[
https://issues.apache.org/jira/browse/KAFKA-9144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-9144:
---
Affects Version/s: 2.0.1
2.1.1
2.2.2
omkreddy commented on a change in pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#discussion_r451674847
##
File path: core/src/test/scala/unit/kafka/admin/AclCommandTest.scala
##
@@ -127,25 +131,53 @@ class AclCommandTest extends ZooKeeperTestHarness with
Lo
hachikuji commented on a change in pull request #8864:
URL: https://github.com/apache/kafka/pull/8864#discussion_r451682470
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -1447,6 +1451,7 @@ public void
testListConsumerGroups
guozhangwang merged pull request #8934:
URL: https://github.com/apache/kafka/pull/8934
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
guozhangwang commented on pull request #8934:
URL: https://github.com/apache/kafka/pull/8934#issuecomment-655636676
Cherry-picked to 2.6.
This is an automated message from the Apache Git Service.
To respond to the message, pl
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153757#comment-17153757
]
Guozhang Wang commented on KAFKA-10134:
---
I've merged the PR and would like [~seang
tombentley commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655641999
@omkreddy, sorry about that, now fixed.
This is an automated message from the Apache Git Service.
To respond to
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153768#comment-17153768
]
Werner Daehn commented on KAFKA-10226:
--
Here is my verdict after testing:
Producer
vvcephei commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-655648704
Failure was unrelated:
kafka.api.SaslMultiMechanismConsumerTest.testCoordinatorFailover
This is an automated mes
omkreddy commented on pull request #8808:
URL: https://github.com/apache/kafka/pull/8808#issuecomment-655651164
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
[
https://issues.apache.org/jira/browse/KAFKA-10226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153768#comment-17153768
]
Werner Daehn edited comment on KAFKA-10226 at 7/8/20, 5:26 PM:
---
vvcephei commented on a change in pull request #8993:
URL: https://github.com/apache/kafka/pull/8993#discussion_r451712293
##
File path: tests/kafkatest/tests/streams/streams_application_upgrade_test.py
##
@@ -0,0 +1,297 @@
+# Licensed to the Apache Software Foundation (ASF) un
John Roesler created KAFKA-10247:
Summary: Streams may attempt to process after closing a task
Key: KAFKA-10247
URL: https://issues.apache.org/jira/browse/KAFKA-10247
Project: Kafka
Issue Typ
vvcephei opened a new pull request #8994:
URL: https://github.com/apache/kafka/pull/8994
The definition of `Task#process` allows for returning `false`
if the task isn't "processable" right now. We can conveniently
resolve KAFKA-10247 by simply considering a task not
processable when
[
https://issues.apache.org/jira/browse/KAFKA-10247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10247:
-
Priority: Blocker (was: Major)
> Streams may attempt to process after closing a task
>
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153852#comment-17153852
]
Neo Wu commented on KAFKA-10134:
Hi, [~guozhang]
Your latest change fixed all my issues
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10134.
---
Resolution: Fixed
> High CPU issue during rebalance in Kafka consumer after upgrading to 2.5
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153861#comment-17153861
]
Guozhang Wang commented on KAFKA-10134:
---
Thanks for the confirmation! I'm resolvin
[
https://issues.apache.org/jira/browse/KAFKA-10134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153862#comment-17153862
]
Guozhang Wang commented on KAFKA-10134:
---
cc 2.5.1 release manager [~vvcephei] I'm
mjsax commented on pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#issuecomment-655701085
It seem the root cause of the issue is that we don't cleanup internal data
structures correctly when closing a task dirty? Should the task not be removed
from the list of active tas
cmccabe merged pull request #8985:
URL: https://github.com/apache/kafka/pull/8985
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
JimGalasyn opened a new pull request #8995:
URL: https://github.com/apache/kafka/pull/8995
The stream-table duality section was dropped inadvertently sometime after
version 0.11.0, so this PR restores it.
This is an automate
[
https://issues.apache.org/jira/browse/KAFKA-10218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153936#comment-17153936
]
Chris Egerton commented on KAFKA-10218:
---
[~rhauch] The primary impact here is that
vvcephei commented on pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#issuecomment-655721490
Hey @abbccdda and @mjsax , thanks for taking a look! The PR is not complete
yet. I'll let you know when it's ready for review.
--
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153975#comment-17153975
]
John Roesler commented on KAFKA-8770:
-
Hi [~davispw] ,
That's a good idea. I'll spli
John Roesler created KAFKA-10248:
Summary: Drop idempotent KTable source updates
Key: KAFKA-10248
URL: https://issues.apache.org/jira/browse/KAFKA-10248
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153976#comment-17153976
]
John Roesler commented on KAFKA-10248:
--
This was implemented in this commit:
{code:
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10248:
-
Fix Version/s: 2.6.0
> Drop idempotent KTable source updates
> -
[
https://issues.apache.org/jira/browse/KAFKA-10248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler resolved KAFKA-10248.
--
Resolution: Fixed
> Drop idempotent KTable source updates
> --
[
https://issues.apache.org/jira/browse/KAFKA-8770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17153977#comment-17153977
]
John Roesler commented on KAFKA-8770:
-
Ok, I created (and resolved) a subtask, which
mjsax commented on a change in pull request #8995:
URL: https://github.com/apache/kafka/pull/8995#discussion_r451796320
##
File path: docs/streams/core-concepts.html
##
@@ -170,13 +150,59 @@ Duality of
or to run interactive
queries
against your application's late
junrao commented on pull request #8974:
URL: https://github.com/apache/kafka/pull/8974#issuecomment-655734288
System test results. All 9 failures seem unrelated to this PR.
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/2020-07-07--001.1594186925--chia7
junrao merged pull request #8974:
URL: https://github.com/apache/kafka/pull/8974
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-10225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-10225.
-
Fix Version/s: 2.7.0
Resolution: Fixed
merged the PR to trunk
> Increase default zk session time
junrao commented on a change in pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#discussion_r451224908
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -47,7 +47,10 @@ def __init__(self, test_context):
self.num_output_partitions = 3
junrao commented on pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#issuecomment-655737852
triggered a system test run
This is an automated message from the Apache Git Service.
To respond to the message, pl
JimGalasyn commented on a change in pull request #8995:
URL: https://github.com/apache/kafka/pull/8995#discussion_r451809936
##
File path: docs/streams/core-concepts.html
##
@@ -170,13 +150,59 @@ Duality of
or to run interactive
queries
against your application's
Sophie Blee-Goldman created KAFKA-10249:
---
Summary: In-memory stores are skipped when checkpointing but not
skipped when reading the checkpoint
Key: KAFKA-10249
URL: https://issues.apache.org/jira/browse/KAFK
kkonstantine commented on a change in pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#discussion_r451832657
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java
##
@@ -76,6 +78,15 @@ public void setup()
kkonstantine commented on pull request #8928:
URL: https://github.com/apache/kafka/pull/8928#issuecomment-655764773
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
ableegoldman opened a new pull request #8996:
URL: https://github.com/apache/kafka/pull/8996
We have this asymmetry in how the ProcessorStateManager handles in-memory
stores: we explicitly skip over them when writing offsets to the checkpoint
file, but don't do the same when reading from t
Rishank Chandra Puram created KAFKA-10250:
-
Summary: Kafka broker shrinks the ISRs and disconnects from other
brokers for few seconds
Key: KAFKA-10250
URL: https://issues.apache.org/jira/browse/KAFKA-10250
[
https://issues.apache.org/jira/browse/KAFKA-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154043#comment-17154043
]
Rishank Chandra Puram commented on KAFKA-10250:
---
1. When the issue occurs,
[
https://issues.apache.org/jira/browse/KAFKA-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rishank Chandra Puram updated KAFKA-10250:
--
Description:
The following the summary/overview of the whole issue. Can you pl
mjsax commented on pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#issuecomment-655783477
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log o
[
https://issues.apache.org/jira/browse/KAFKA-10250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154043#comment-17154043
]
Rishank Chandra Puram edited comment on KAFKA-10250 at 7/8/20, 10:09 PM:
-
rhauch commented on a change in pull request #8864:
URL: https://github.com/apache/kafka/pull/8864#discussion_r451856474
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java
##
@@ -148,6 +148,7 @@ public KafkaStatusBackingSt
vvcephei commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451860750
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -766,6 +769,24 @@ void runOnce() {
retur
ableegoldman commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451862588
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -766,6 +769,24 @@ void runOnce() {
r
vvcephei commented on pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#issuecomment-655792712
Ok, @abbccdda and @mjsax , I think this is ready for a review now. I'm not
very happy with the logic to reset to the last committed offset. Can you think
of a better way to do it
apovzner commented on a change in pull request #8977:
URL: https://github.com/apache/kafka/pull/8977#discussion_r451871529
##
File path: clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java
##
@@ -97,7 +97,25 @@ public static RecordingLevel forName(String name) {
ableegoldman commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451884449
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -95,7 +96,7 @@
* | | Assi
ableegoldman commented on pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#issuecomment-655815316
Hey @vvcephei , do you think we should ask about cherrypicking this back to
2.6 to help stabilize the release? I thought failing system tests (or regularly
failing tests of a
ableegoldman commented on pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#issuecomment-655825204
Two failures:
`TransactionsBounceTest.testWithGroupMetadata`
`SmokeTestDriverIntegrationTest.shouldWorkWithRebalance`
The `shouldWorkWithRebalance` failure is actu
mjsax commented on a change in pull request #8994:
URL: https://github.com/apache/kafka/pull/8994#discussion_r451895176
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -193,6 +197,28 @@ private void closeAndRevive(final M
chia7712 commented on a change in pull request #8981:
URL: https://github.com/apache/kafka/pull/8981#discussion_r451898731
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -47,7 +47,10 @@ def __init__(self, test_context):
self.num_output_partitions =
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451899726
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void initializeStoreOffset
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451900686
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void initializeStoreOffset
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451901975
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void close() {
mjsax commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451902131
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -813,6 +813,62 @@ public void
shouldTh
mjsax commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r451903126
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java
##
@@ -45,24 +45,23 @@
protected Processo
mjsax closed pull request #8855:
URL: https://github.com/apache/kafka/pull/8855
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
Sophie Blee-Goldman created KAFKA-10251:
---
Summary: Flaky Test
kafka.api.TransactionsBounceTest.testWithGroupMetadata
Key: KAFKA-10251
URL: https://issues.apache.org/jira/browse/KAFKA-10251
Proje
[
https://issues.apache.org/jira/browse/KAFKA-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154110#comment-17154110
]
Sophie Blee-Goldman commented on KAFKA-10251:
-
cc [~bchen225242] –
[https:/
guozhangwang opened a new pull request #8997:
URL: https://github.com/apache/kafka/pull/8997
Add log4j entry summarizing the assignment (prev owned and assigned) at the
consumer level.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
guozhangwang commented on pull request #8997:
URL: https://github.com/apache/kafka/pull/8997#issuecomment-655841394
@ableegoldman @abbccdda
This is an automated message from the Apache Git Service.
To respond to the message,
guozhangwang commented on a change in pull request #8997:
URL: https://github.com/apache/kafka/pull/8997#discussion_r451912298
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -66,32 +72,17 @@ public ClientState
[
https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17154113#comment-17154113
]
Sophie Blee-Goldman commented on KAFKA-8940:
Failed again:
h3. Error Message
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451922040
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java
##
@@ -224,6 +224,9 @@ void initializeStor
ableegoldman commented on a change in pull request #8996:
URL: https://github.com/apache/kafka/pull/8996#discussion_r451922421
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorStateManagerTest.java
##
@@ -784,7 +784,7 @@ public void clo
1 - 100 of 123 matches
Mail list logo
