dielhennr removed a comment on pull request #11141:
URL: https://github.com/apache/kafka/pull/11141#issuecomment-892359084
@hachikuji @rajinisivaram since this build is green I’m fairly confident
that dynamic configs in a zk cluster haven’t changed behavior. I am wondering
if it would be
dielhennr edited a comment on pull request #11141:
URL: https://github.com/apache/kafka/pull/11141#issuecomment-892359084
@hachikuji @rajinisivaram since this build is green I’m fairly confident
that dynamic configs in a zk cluster haven’t changed behavior. I am wondering
if it would be
dielhennr commented on pull request #11141:
URL: https://github.com/apache/kafka/pull/11141#issuecomment-892359084
@hachikuji @rajinisivaram since this build is green I’m fairly confident
that dynamic configs in a zk cluster haven’t changed behavior. I am wondering
if it would be better
ccding commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r682281792
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1434,6 +1434,9 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
vvcephei commented on pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#issuecomment-892354449
I went ahead and kicked off a full system test build to evaluate the other
tests that got changed in this PR:
vvcephei commented on pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#issuecomment-892354208
Ok, I figured it out. The problem was that this change was adding the new
version(s) to the _metadata_ upgrade test, but there isn't a metadata upgrade
between 2.x and 3.0.
vvcephei commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r682270517
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to
vvcephei commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r682270266
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
##
@@ -0,0 +1,299 @@
+/*
+ * Licensed
dengziming commented on pull request #11173:
URL: https://github.com/apache/kafka/pull/11173#issuecomment-892334259
cc @dajac @thomaskwscott .欄
--
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
dengziming opened a new pull request #11173:
URL: https://github.com/apache/kafka/pull/11173
*More detailed description of your change*
Support max timestamp in GetOffsetShell which we added in KIP-734
--
This is an automated message from the Apache Git Service.
To respond to
ijuma commented on a change in pull request #0:
URL: https://github.com/apache/kafka/pull/0#discussion_r682253716
##
File path: core/src/main/scala/kafka/server/KafkaConfig.scala
##
@@ -1434,6 +1434,9 @@ class KafkaConfig(val props: java.util.Map[_, _], doLog:
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682238334
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -248,12 +249,29 @@ public
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682237513
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -53,44 +56,162 @@
private static
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682235008
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -935,6 +944,14 @@ void shutdown(final
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682234726
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -53,44 +56,162 @@
private static
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682233727
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java
##
@@ -53,44 +56,162 @@
private static
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682231789
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java
##
@@ -105,31
showuon commented on a change in pull request #11124:
URL: https://github.com/apache/kafka/pull/11124#discussion_r682231711
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregateTest.java
##
@@ -100,17 +99,79 @@
ccding commented on pull request #0:
URL: https://github.com/apache/kafka/pull/0#issuecomment-892299485
Included the motivation and updated the PR. PTAL @ijuma @junrao @kowshik
@satishd
--
This is an automated message from the Apache Git Service.
To respond to the message,
ableegoldman commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682230209
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java
##
@@ -64,6 +65,9 @@
private final Map
[
https://issues.apache.org/jira/browse/KAFKA-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen resolved KAFKA-13145.
---
Resolution: Won't Fix
> Renaming the time interval window for better understanding
>
[
https://issues.apache.org/jira/browse/KAFKA-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392626#comment-17392626
]
Luke Chen commented on KAFKA-13145:
---
I'm good. I'll close this ticket and add `SlidingWindow` class
hachikuji commented on a change in pull request #11171:
URL: https://github.com/apache/kafka/pull/11171#discussion_r682206623
##
File path: core/src/main/scala/kafka/cluster/Partition.scala
##
@@ -313,14 +313,20 @@ class Partition(val topicPartition: TopicPartition,
}
ableegoldman commented on pull request #10568:
URL: https://github.com/apache/kafka/pull/10568#issuecomment-892279085
1) Possibly -- you can check out the [Streams upgrade
guide](https://kafka.apache.org/28/documentation/streams/upgrade-guide), which
describes any public API changes in
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Summary: Fix the code that calls the broker’s config handler to pass the
expected default
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Summary: Fix the code the calls the broker’s config handler to pass the
expected default
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682020580
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -628,26 +634,43 @@ private[log] class Cleaner(val id: Int,
* @param
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682018753
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -270,7 +270,8 @@ class Log(@volatile private var _dir: File,
val
[
https://issues.apache.org/jira/browse/KAFKA-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392615#comment-17392615
]
A. Sophie Blee-Goldman commented on KAFKA-13145:
Fine with me. FWIW the
[
https://issues.apache.org/jira/browse/KAFKA-13150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392612#comment-17392612
]
Matthias J. Sax commented on KAFKA-13150:
-
To subscribe, follow instruction on the webpage:
codefactor commented on pull request #10568:
URL: https://github.com/apache/kafka/pull/10568#issuecomment-892269776
@ableegoldman ,
Thanks a lot - do you have any links where I can find out the following:
1. are there any breaking changes if I upgrade from version 2.6 to 3.0?
2.
[
https://issues.apache.org/jira/browse/KAFKA-13152?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13152:
Labels: needs-kip (was: )
> Replace "buffered.records.per.partition" with
[
https://issues.apache.org/jira/browse/KAFKA-13145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392611#comment-17392611
]
Matthias J. Sax commented on KAFKA-13145:
-
Personally, I am not a fan on
[
https://issues.apache.org/jira/browse/KAFKA-12559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392610#comment-17392610
]
A. Sophie Blee-Goldman commented on KAFKA-12559:
[~brz] I'd say give [~msundeq] another
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682020580
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -628,26 +634,43 @@ private[log] class Cleaner(val id: Int,
* @param
mjsax commented on a change in pull request #11124:
URL: https://github.com/apache/kafka/pull/11124#discussion_r682192656
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindow.java
##
@@ -19,33 +19,24 @@
import
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682018753
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -270,7 +270,8 @@ class Log(@volatile private var _dir: File,
val
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
Jason Gustafson created KAFKA-13162:
---
Summary: ElectLeader API must be forwarded to Controller
Key: KAFKA-13162
URL: https://issues.apache.org/jira/browse/KAFKA-13162
Project: Kafka
Issue
mjsax commented on pull request #11157:
URL: https://github.com/apache/kafka/pull/11157#issuecomment-892262404
Thanks for the PR @dengziming! Merged to `trunk`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
mjsax merged pull request #11157:
URL: https://github.com/apache/kafka/pull/11157
--
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 specific comment.
To unsubscribe, e-mail:
Jason Gustafson created KAFKA-13161:
---
Summary: Follower leader and ISR state not updated after partition
change in KRaft
Key: KAFKA-13161
URL: https://issues.apache.org/jira/browse/KAFKA-13161
mjsax commented on pull request #11172:
URL: https://github.com/apache/kafka/pull/11172#issuecomment-892239651
\cc @kkonstantine
--
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 specific
mjsax opened a new pull request #11172:
URL: https://github.com/apache/kafka/pull/11172
Call for review @JimGalasyn @spena @ableegoldman (cf
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Join+Semantics)
Must be cherry-picked to `3.0` branch.
--
This is an
guozhangwang commented on a change in pull request #10788:
URL: https://github.com/apache/kafka/pull/10788#discussion_r682090255
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTaskCreator.java
##
@@ -66,14 +72,26 @@
);
}
ableegoldman commented on pull request #10568:
URL: https://github.com/apache/kafka/pull/10568#issuecomment-892231916
@codefactor it will be released in 3.0, which is currently in the final
stages of testing and preparing for release.
--
This is an automated message from the Apache Git
cmccabe commented on pull request #11168:
URL: https://github.com/apache/kafka/pull/11168#issuecomment-892230644
I don't think this is the right place to make this change.
BrokerMetadataPublisher should be calling `processConfigChanges` with the
expected name, instead.
--
This is an
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682164477
##
File path:
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsTest.java
##
@@ -483,6 +486,49 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
jolshan opened a new pull request #11171:
URL: https://github.com/apache/kafka/pull/11171
Most of [KAFKA-13132](https://issues.apache.org/jira/browse/KAFKA-13132) has
been resolved, but there is one part of one case not covered.
From the ticket:
`2. We only assign the topic ID when
codefactor commented on pull request #10568:
URL: https://github.com/apache/kafka/pull/10568#issuecomment-892207657
Any plans that this will be released?
It looks like this upgrade happens to include the following issue fix in
rocksdb:
[
https://issues.apache.org/jira/browse/KAFKA-12395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hiro Kuwabara reassigned KAFKA-12395:
-
Assignee: Hiro Kuwabara
> Drop topic mapKey in DeleteTopics response
>
mjsax commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r682120783
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestUtil.java
##
@@ -0,0 +1,134 @@
+/*
+ * Licensed to the
jolshan opened a new pull request #11170:
URL: https://github.com/apache/kafka/pull/11170
Before we used the metadata cache to determine whether or not to use topic
IDs. Unfortunately, metadata cache updates with ZK controllers are in a
separate request and may be too slow for the fetcher
mjsax commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r682119892
##
File path:
streams/upgrade-system-tests-28/src/test/java/org/apache/kafka/streams/tests/SmokeTestClient.java
##
@@ -0,0 +1,299 @@
+/*
+ * Licensed to
mjsax commented on a change in pull request #10602:
URL: https://github.com/apache/kafka/pull/10602#discussion_r682119041
##
File path: tests/kafkatest/tests/streams/streams_upgrade_test.py
##
@@ -25,15 +25,17 @@
from kafkatest.services.zookeeper import ZookeeperService
from
[
https://issues.apache.org/jira/browse/KAFKA-13132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reopened KAFKA-13132:
Found an issue where we don't sufficiently cover case 2. I have a plan to
properly cover.
Borzoo opened a new pull request #11169:
URL: https://github.com/apache/kafka/pull/11169
*More detailed description of your change,
Added the missing @Test annotation to a test in FileStreamSourceTaskTest.
The test used to loop 100 times, each time blocking for 1 second. Checking the
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12994:
---
Labels: kip-633 newbie newbie++ (was: kip kip-633)
> Migrate all Tests to
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12994:
--
Assignee: A. Sophie Blee-Goldman
> Migrate all Tests to New API and
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12994:
--
Assignee: (was: Israel Ekpo)
> Migrate all Tests to New API and
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12994:
--
Assignee: (was: A. Sophie Blee-Goldman)
> Migrate all Tests to
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392530#comment-17392530
]
A. Sophie Blee-Goldman commented on KAFKA-12994:
Hey [~iekpo], I'm unassigning this in
[
https://issues.apache.org/jira/browse/KAFKA-12994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12994:
---
Fix Version/s: (was: 3.0.0)
3.1.0
> Migrate all
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description:
In a ZK cluster, dynamic default broker configs are stored in the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description: In a ZK cluster, dynamic default broker configs are stored in
the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description: In a ZK cluster, dynamic default broker configs are stored in
the zNode
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description: In a ZK cluster, dynamic default broker configs are stored in
the zNode
mumrah edited a comment on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892069170
Streams smoke test:
~https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4630/~
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4631/
[
https://issues.apache.org/jira/browse/KAFKA-12646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-12646.
Resolution: Fixed
> Implement snapshot generation on brokers
>
[
https://issues.apache.org/jira/browse/KAFKA-12647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-12647.
Resolution: Fixed
> Implement loading snapshot in the broker
>
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682020580
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -628,26 +634,43 @@ private[log] class Cleaner(val id: Int,
* @param
[
https://issues.apache.org/jira/browse/KAFKA-13160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ryan Dielhenn updated KAFKA-13160:
--
Description: In a ZK cluster, dynamic default broker configs are stored in
the zNode
dielhennr opened a new pull request #11168:
URL: https://github.com/apache/kafka/pull/11168
The KRaft brokers are throwing NumberFormatException when processing dynamic
default broker config updates because they expect the default entity name that
was used in zookeeper to be the resource
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682018753
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -270,7 +270,8 @@ class Log(@volatile private var _dir: File,
val
wycc opened a new pull request #11167:
URL: https://github.com/apache/kafka/pull/11167
Development of EasyMock and PowerMock has stagnated while Mockito continues
to be actively developed. With the new Java cadence, it's a problem to depend
on libraries that do bytecode generation and
Ryan Dielhenn created KAFKA-13160:
-
Summary: Fix BrokerConfigHandler to expect empty string as the
resource name for dynamic default broker configs in KRaft
Key: KAFKA-13160
URL:
mattwong949 commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r682012434
##
File path: core/src/main/scala/kafka/log/LogCleaner.scala
##
@@ -628,26 +634,43 @@ private[log] class Cleaner(val id: Int,
* @param
[
https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Arthur updated KAFKA-13159:
-
Fix Version/s: 3.1.0
> Enable system tests for transactions in KRaft mode
>
rondagostino commented on a change in pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#discussion_r682008773
##
File path: tests/kafkatest/tests/core/replication_test.py
##
@@ -122,14 +122,16 @@ def min_cluster_size(self):
[
https://issues.apache.org/jira/browse/KAFKA-13159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17392468#comment-17392468
]
David Arthur commented on KAFKA-13159:
--
The main transactions_test.py were enabled on 3.0 branch
David Arthur created KAFKA-13159:
Summary: Enable system tests for transactions in KRaft mode
Key: KAFKA-13159
URL: https://issues.apache.org/jira/browse/KAFKA-13159
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-12997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-12997.
Resolution: Fixed
> Expose log record append time to the
YI-CHEN WANG created KAFKA-13158:
Summary: Replace EasyMock and PowerMock with Mockito for
ConnectClusterStateImpl Test and ConnectorPluginsResourceTest
Key: KAFKA-13158
URL:
mumrah commented on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892069170
Streams smoke test:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4630/
--
This is an automated message from the Apache Git Service.
To respond to the
mumrah commented on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892068893
Group mode transactions:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4629/
--
This is an automated message from the Apache Git Service.
To respond to the
[
https://issues.apache.org/jira/browse/KAFKA-12973?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-12973:
--
Assignee: Jose Armando Garcia Sancio
> Update KIP and dev
mumrah commented on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892068421
Produce bench:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4628/
--
This is an automated message from the Apache Git Service.
To respond to the message,
mumrah commented on pull request #11166:
URL: https://github.com/apache/kafka/pull/11166#issuecomment-892067696
Replication test run:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/4627/
--
This is an automated message from the Apache Git Service.
To respond to the
mumrah opened a new pull request #11166:
URL: https://github.com/apache/kafka/pull/11166
--
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 specific comment.
To unsubscribe, e-mail:
mumrah commented on pull request #11165:
URL: https://github.com/apache/kafka/pull/11165#issuecomment-892065979
Opening a follow-on PR for the additional tests mentioned by @rondagostino
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
mumrah merged pull request #11165:
URL: https://github.com/apache/kafka/pull/11165
--
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 specific comment.
To unsubscribe, e-mail:
Jose Armando Garcia Sancio created KAFKA-13157:
--
Summary: Kafka-dump-log needs to support snapshot records
Key: KAFKA-13157
URL: https://issues.apache.org/jira/browse/KAFKA-13157
Project:
hachikuji commented on a change in pull request #10914:
URL: https://github.com/apache/kafka/pull/10914#discussion_r681961452
##
File path:
clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java
##
@@ -80,6 +80,7 @@ public void write(int b) {
dielhennr commented on a change in pull request #11159:
URL: https://github.com/apache/kafka/pull/11159#discussion_r681972655
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java
##
@@ -239,11 +239,11 @@ public void
1 - 100 of 114 matches
Mail list logo
