Vagesh Mathapati created KAFKA-10396:
Summary: Overall memory of container keep on growing due to kafka
stream / rocksdb and OOM killed once limit reached
Key: KAFKA-10396
URL: https://issues.apache.org/jira/b
[
https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176796#comment-17176796
]
feyman commented on KAFKA-10307:
Hi, [~vvcephei]
I'm running with the trunk branch but
JoelWee commented on a change in pull request #8923:
URL: https://github.com/apache/kafka/pull/8923#discussion_r469725796
##
File path: core/src/main/scala/kafka/tools/StreamsResetter.java
##
@@ -646,22 +655,68 @@ private boolean isIntermediateTopic(final String topic) {
JoelWee commented on a change in pull request #8923:
URL: https://github.com/apache/kafka/pull/8923#discussion_r469722613
##
File path: docs/streams/developer-guide/app-reset-tool.html
##
@@ -77,6 +77,7 @@
Step 1: Run the application reset tool
abbccdda commented on a change in pull request #9174:
URL: https://github.com/apache/kafka/pull/9174#discussion_r469713175
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java
##
@@ -805,10 +805,10 @@ public void advanceWallClockTime(
albert02lowis commented on a change in pull request #9108:
URL: https://github.com/apache/kafka/pull/9108#discussion_r469707761
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
##
@@ -123,25 +117,18 @@
public static
albert02lowis commented on a change in pull request #9108:
URL: https://github.com/apache/kafka/pull/9108#discussion_r469704319
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
##
@@ -123,25 +117,18 @@
public static
albert02lowis commented on a change in pull request #9108:
URL: https://github.com/apache/kafka/pull/9108#discussion_r469704319
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
##
@@ -123,25 +117,18 @@
public static
RamanVerma commented on a change in pull request #9112:
URL: https://github.com/apache/kafka/pull/9112#discussion_r469698016
##
File path: core/src/test/scala/unit/kafka/server/MetadataCacheTest.scala
##
@@ -187,49 +191,24 @@ class MetadataCacheTest {
new UpdateMetadataB
[
https://issues.apache.org/jira/browse/KAFKA-10391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang resolved KAFKA-10391.
---
Fix Version/s: 2.7.0
Resolution: Fixed
> Streams should overwrite checkpoint excludin
guozhangwang merged pull request #9170:
URL: https://github.com/apache/kafka/pull/9170
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
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469680702
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java
##
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the
chia7712 commented on pull request #9162:
URL: https://github.com/apache/kafka/pull/9162#issuecomment-673212958
```org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest >
shouldUpgradeFromEosAlphaToEosBeta[true]``` failed. I test it on my local and
it pass. retest this please
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469650293
##
File path:
core/src/test/scala/unit/kafka/admin/UserScramCredentialsCommandTest.scala
##
@@ -0,0 +1,127 @@
+/**
+ * Licensed to the Apache Software
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469646777
##
File path:
core/src/test/scala/unit/kafka/admin/UserScramCredentialsCommandTest.scala
##
@@ -0,0 +1,127 @@
+/**
+ * Licensed to the Apache Software
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469646777
##
File path:
core/src/test/scala/unit/kafka/admin/UserScramCredentialsCommandTest.scala
##
@@ -0,0 +1,127 @@
+/**
+ * Licensed to the Apache Software
ableegoldman commented on pull request #9174:
URL: https://github.com/apache/kafka/pull/9174#issuecomment-673189749
@cadonna @guozhangwang
This is an automated message from the Apache Git Service.
To respond to the message,
hachikuji commented on pull request #9163:
URL: https://github.com/apache/kafka/pull/9163#issuecomment-673189746
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please l
ableegoldman opened a new pull request #9174:
URL: https://github.com/apache/kafka/pull/9174
I went through all 5 stages of grief in thinking about what to do here and
decided the best thing was to just relax the check after all. Hopefully users
who find their output topic unexpectedly emp
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469637266
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/UserScramCredentialUpsertion.java
##
@@ -0,0 +1,99 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman reassigned KAFKA-10395:
---
Assignee: Sophie Blee-Goldman
> TopologyTestDriver does not work with dynam
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176675#comment-17176675
]
Sophie Blee-Goldman commented on KAFKA-10395:
-
The only really holistic solu
[
https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10042.
-
Resolution: Fixed
> Make INVALID_PRODUCER_EPOCH abortable from Produce response
> --
[
https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-10042:
---
Assignee: Boyang Chen
> Make INVALID_PRODUCER_EPOCH abortable from Produce response
> -
[
https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10042:
Fix Version/s: 2.7.0
> Make INVALID_PRODUCER_EPOCH abortable from Produce response
> -
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176665#comment-17176665
]
Sophie Blee-Goldman edited comment on KAFKA-10395 at 8/13/20, 12:41 AM:
--
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469627624
##
File path:
core/src/test/scala/unit/kafka/server/DescribeUserScramCredentialsRequestTest.scala
##
@@ -0,0 +1,128 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9803:
---
Fix Version/s: 2.7.0
> Allow producers to recover gracefully from transaction timeouts
>
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176665#comment-17176665
]
Sophie Blee-Goldman edited comment on KAFKA-10395 at 8/13/20, 12:36 AM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10395:
Labels: test-framework (was: needs-kip test-framework)
> TopologyTestDriver does
showuon commented on pull request #9104:
URL: https://github.com/apache/kafka/pull/9104#issuecomment-673173805
@kkonstantine , could you review this PR? Thanks.
This is an automated message from the Apache Git Service.
To res
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176665#comment-17176665
]
Sophie Blee-Goldman commented on KAFKA-10395:
-
I think we could just modify
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10395:
Labels: needs-kip test-framework (was: test-framework)
> TopologyTestDriver does
[
https://issues.apache.org/jira/browse/KAFKA-10395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10395:
Labels: test-framework (was: )
> TopologyTestDriver does not work with dynamic to
Sophie Blee-Goldman created KAFKA-10395:
---
Summary: TopologyTestDriver does not work with dynamic topic
routing
Key: KAFKA-10395
URL: https://issues.apache.org/jira/browse/KAFKA-10395
Project: Ka
badaiaqrandista commented on pull request #9099:
URL: https://github.com/apache/kafka/pull/9099#issuecomment-673156754
@dajac Can you please re-review the changes I've made?
This is an automated message from the Apache Git Se
[
https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
HaiyuanZhao reassigned KAFKA-9910:
--
Assignee: HaiyuanZhao
> Implement new transaction timed out error
> --
bbejeck commented on a change in pull request #9108:
URL: https://github.com/apache/kafka/pull/9108#discussion_r469593164
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
##
@@ -123,25 +117,18 @@
public static void
bbejeck commented on a change in pull request #9108:
URL: https://github.com/apache/kafka/pull/9108#discussion_r469593164
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/AbstractJoinIntegrationTest.java
##
@@ -123,25 +117,18 @@
public static void
ableegoldman commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r469593402
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -1069,6 +1069,13 @@ private HeartbeatRe
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10284:
Priority: Critical (was: Major)
> Group membership update due to static member re
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-10284:
---
Assignee: Boyang Chen
> Group membership update due to static member rejoin should be persi
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176639#comment-17176639
]
Boyang Chen edited comment on KAFKA-10284 at 8/12/20, 10:48 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10284:
Fix Version/s: (was: 2.6.1)
> Group membership update due to static member rej
[
https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176639#comment-17176639
]
Boyang Chen commented on KAFKA-10284:
-
I would say for all.
> Group membership upda
[
https://issues.apache.org/jira/browse/KAFKA-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176636#comment-17176636
]
Randall Hauch commented on KAFKA-9066:
--
Merged https://github.com/apache/kafka/pull/
ableegoldman commented on a change in pull request #8834:
URL: https://github.com/apache/kafka/pull/8834#discussion_r469587219
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java
##
@@ -528,7 +528,6 @@ public void onFailure(
rhauch merged pull request #8854:
URL: https://github.com/apache/kafka/pull/8854
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-9066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-9066:
-
Fix Version/s: 2.5.2
> Kafka Connect JMX : source & sink task metrics missing for tasks in failed
svudutala commented on pull request #7898:
URL: https://github.com/apache/kafka/pull/7898#issuecomment-673145549
@dongjinleekr What is timeline for merging this PR and making this upgrade
available?
This is an automated mes
rhauch commented on a change in pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#discussion_r469586764
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java
##
@@ -318,4 +323,61 @@ public void test
rajinisivaram merged pull request #9168:
URL: https://github.com/apache/kafka/pull/9168
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
rajinisivaram commented on pull request #9168:
URL: https://github.com/apache/kafka/pull/9168#issuecomment-673144455
@ijuma Thanks for the review, streams test failures not related. Merging to
trunk, 2.6, 2,5 and 2.4.
This i
ableegoldman commented on pull request #9173:
URL: https://github.com/apache/kafka/pull/9173#issuecomment-673143739
Closing this since I didn't see the existing PR for this bugfix:
https://github.com/apache/kafka/pull/8834
T
ableegoldman closed pull request #9173:
URL: https://github.com/apache/kafka/pull/9173
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 #9094:
URL: https://github.com/apache/kafka/pull/9094#discussion_r469582284
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java
##
@@ -289,6 +294,25 @@ public stat
ableegoldman commented on a change in pull request #9094:
URL: https://github.com/apache/kafka/pull/9094#discussion_r469582284
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ProcessorNodeMetrics.java
##
@@ -289,6 +294,25 @@ public stat
kkonstantine commented on a change in pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#discussion_r469578195
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java
##
@@ -318,4 +323,61 @@ public voi
kkonstantine commented on a change in pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#discussion_r469577371
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
##
@@ -129,7 +129,8 @@ public SourceConnectorC
kkonstantine commented on pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#issuecomment-673136551
According to https://status.apache.org the jenkins queue has grown too much
and the infra team is investigating how to resolve the issues. Thus, the tests
haven't run yet.
rhauch commented on a change in pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#discussion_r469574130
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/integration/TransformationIntegrationTest.java
##
@@ -318,4 +323,61 @@ public void test
[
https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch updated KAFKA-10387:
--
Priority: Critical (was: Major)
> Cannot include SMT configs with source connector that uses
d8tltanc commented on pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#issuecomment-673114249
@abbccdda Thanks for the review offers! I'll rebase this PR.
This is an automated message from the Apache Git Ser
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r468736687
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -721,6 +730,11 @@ protected Node curNode() {
r
vvcephei removed a comment on pull request #9098:
URL: https://github.com/apache/kafka/pull/9098#issuecomment-673100824
@cadonna :
```
> Task :streams:checkstyleMain
[ant:checkstyle] [ERROR]
/home/confluent/kafka/streams/src/generated/java/org/apache/kafka/streams/InteractiveQ
vvcephei commented on pull request #9098:
URL: https://github.com/apache/kafka/pull/9098#issuecomment-673100824
@cadonna :
```
> Task :streams:checkstyleMain
[ant:checkstyle] [ERROR]
/home/confluent/kafka/streams/src/generated/java/org/apache/kafka/streams/InteractiveQueryPart
guozhangwang commented on a change in pull request #9170:
URL: https://github.com/apache/kafka/pull/9170#discussion_r469518409
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java
##
@@ -58,6 +58,9 @@ static boolean checkpointN
guozhangwang commented on a change in pull request #9170:
URL: https://github.com/apache/kafka/pull/9170#discussion_r469517595
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -193,13 +193,17 @@ private void closeAndRevive
guozhangwang commented on pull request #9170:
URL: https://github.com/apache/kafka/pull/9170#issuecomment-673090664
> Do you have any theories as to why this was causing
`StreamsUpgradeTest.test_app_upgrade` to be flaky? Do we really get that many
TaskCorruptedExceptions in this system tes
vvcephei commented on pull request #9098:
URL: https://github.com/apache/kafka/pull/9098#issuecomment-673090192
Test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176582#comment-17176582
]
Guozhang Wang commented on KAFKA-10357:
---
I've thought about relaying on the commit
vvcephei commented on pull request #9098:
URL: https://github.com/apache/kafka/pull/9098#issuecomment-673090128
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 #9098:
URL: https://github.com/apache/kafka/pull/9098#issuecomment-673090023
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 #8846:
URL: https://github.com/apache/kafka/pull/8846#issuecomment-673088220
@d8tltanc Thanks for the great work! I could resume reviewing this PR
sometime next week, do you mind rebasing it?
--
abbccdda commented on a change in pull request #9170:
URL: https://github.com/apache/kafka/pull/9170#discussion_r469509680
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -193,13 +193,17 @@ private void closeAndRevive(fin
ableegoldman opened a new pull request #9173:
URL: https://github.com/apache/kafka/pull/9173
We launched a Streams application reading from a single 3000-partition topic
and saw continuous rebalancing. Digging into the logs, every time the leader
sent a SyncGroup request it would discover
kkonstantine commented on pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#issuecomment-673067506
cc @rhauch @wicknicks
This is an automated message from the Apache Git Service.
To respond to the message, p
kkonstantine commented on pull request #9172:
URL: https://github.com/apache/kafka/pull/9172#issuecomment-673065882
I'll be adding a few more tests.
This is an automated message from the Apache Git Service.
To respond to the
kkonstantine opened a new pull request #9172:
URL: https://github.com/apache/kafka/pull/9172
Addition of configs for custom topic creation with KIP-158 created a
regression when transformation configs are also included in the configuration
of a source connector.
To experience the i
[
https://issues.apache.org/jira/browse/KAFKA-10393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-10393:
---
Summary: Message for fetch snapshot and fetch (was: KIP-630: message
Jose Armando Garcia Sancio created KAFKA-10394:
--
Summary: Internal API for generating snapshots
Key: KAFKA-10394
URL: https://issues.apache.org/jira/browse/KAFKA-10394
Project: Kafka
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469476195
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4071,6 +4081,168 @@ void handleFailure(Throwable throw
[
https://issues.apache.org/jira/browse/KAFKA-10393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-10393:
---
Summary: KIP-630: message for fetch snapshot and fetch (was: KIP-630
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r468736687
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -721,6 +730,11 @@ protected Node curNode() {
r
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r468736687
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -721,6 +730,11 @@ protected Node curNode() {
r
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r469473196
##
File path: clients/src/main/java/org/apache/kafka/clients/Metadata.java
##
@@ -74,22 +76,28 @@
private final ClusterResourceListeners clusterResour
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r469472239
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/GeometricProgression.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Fo
d8tltanc commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r469471723
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/GeometricProgression.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Fo
serjchebotarev commented on pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#issuecomment-673049249
@ableegoldman alright, thanks.
This is an automated message from the Apache Git Service.
To respond to the
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r469467881
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -1210,28 +1218,20 @@ class Partition(val topicPartition: TopicPartition,
}
}
[
https://issues.apache.org/jira/browse/KAFKA-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176535#comment-17176535
]
Sophie Blee-Goldman commented on KAFKA-10357:
-
I think the elegant way to sh
mumrah commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r469460462
##
File path: core/src/main/scala/kafka/server/AlterIsrChannelManager.scala
##
@@ -0,0 +1,132 @@
+package kafka.server
+
+import java.util
+import java.util.
rondagostino commented on a change in pull request #9032:
URL: https://github.com/apache/kafka/pull/9032#discussion_r469457068
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -4071,6 +4081,168 @@ void handleFailure(Throwable throw
ableegoldman commented on pull request #9028:
URL: https://github.com/apache/kafka/pull/9028#issuecomment-673036155
@serjchebotarev he's out of office this week, just fyi.
This is an automated message from the Apache Git Ser
ableegoldman commented on a change in pull request #9170:
URL: https://github.com/apache/kafka/pull/9170#discussion_r469450345
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java
##
@@ -1609,12 +1609,11 @@ public void shouldRetu
hachikuji commented on a change in pull request #9100:
URL: https://github.com/apache/kafka/pull/9100#discussion_r469388095
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -748,7 +755,7 @@ class Partition(val topicPartition: TopicPartition,
leaderLogI
Jose Armando Garcia Sancio created KAFKA-10393:
--
Summary: KIP-630: messafe for fetch snapshot and fetch
Key: KAFKA-10393
URL: https://issues.apache.org/jira/browse/KAFKA-10393
Project: Kaf
guozhangwang merged pull request #9171:
URL: https://github.com/apache/kafka/pull/9171
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 pull request #9171:
URL: https://github.com/apache/kafka/pull/9171#issuecomment-673010059
cc @vvcephei @guozhangwang
This is an automated message from the Apache Git Service.
To respond to the messa
ableegoldman opened a new pull request #9171:
URL: https://github.com/apache/kafka/pull/9171
So we don't have to bug the committers to kick off tests 😄
This is an automated message from the Apache Git Service.
To respond to
1 - 100 of 148 matches
Mail list logo
