Satish Duggana created KAFKA-12429:
--
Summary: Serdes for all message types in internal topic which is
used in default implementation for RLMM.
Key: KAFKA-12429
URL: https://issues.apache.org/jira/browse/KAFKA-124
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588095220
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.s
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Satish Duggana updated KAFKA-7739:
--
Description: KIP:
[https://cwiki.apache.org/confluence/display/KAFKA/KIP-405%3A+Kafka+Tiered+St
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588094923
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.s
dajac commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588094059
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.setR
dajac commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588093454
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.setR
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588091547
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.s
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588090869
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.s
dajac commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588075100
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -811,31 +821,40 @@ class KafkaApis(val requestChannel: RequestChannel,
.setR
[
https://issues.apache.org/jira/browse/KAFKA-12404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
YI-CHEN WANG reassigned KAFKA-12404:
Assignee: YI-CHEN WANG
> Provision to propagate error message from Authorizer to clients
dajac commented on pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#issuecomment-791199822
Nice PR! I will take a look at it on Monday.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep updated KAFKA-12416:
Description:
Upon failure of group coordinator, the followers of newly elected group
coordinator are fail
rodesai commented on a change in pull request #10266:
URL: https://github.com/apache/kafka/pull/10266#discussion_r588053733
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -91,6 +104,225 @@ public InternalTopicMa
[
https://issues.apache.org/jira/browse/KAFKA-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep updated KAFKA-12416:
Description:
Upon failure of group coordinator, the followers of newly elected group
coordinator are fail
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295791#comment-17295791
]
Guozhang Wang commented on KAFKA-12428:
---
Thinking about this a bit, maybe it's bet
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588050163
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -795,7 +795,17 @@ class KafkaApis(val requestChannel: RequestChannel,
// the
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588049874
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -294,14 +294,24 @@ trait FetchContext extends Logging {
*/
def updateAndG
chia7712 commented on a change in pull request #10269:
URL: https://github.com/apache/kafka/pull/10269#discussion_r588049196
##
File path: core/src/main/scala/kafka/server/FetchSession.scala
##
@@ -411,54 +436,40 @@ class IncrementalFetchContext(private val time: Time,
}
chia7712 opened a new pull request #10269:
URL: https://github.com/apache/kafka/pull/10269
The fetch data generated by `KafkaApis` is re-grouped when it is converted
to `FetchResponse`. That is unnecessary since `KafkaApis` can keep a grouped
collection for fetch data. The other main chang
[
https://issues.apache.org/jira/browse/KAFKA-12410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-12410:
---
Summary: KafkaAPis ought to group fetch data before generating fetch
response (was: Remove
[
https://issues.apache.org/jira/browse/KAFKA-12412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep resolved KAFKA-12412.
-
Resolution: Fixed
> Group Coordinator followers are failing with OffsetsOutOfOrderException
> --
[
https://issues.apache.org/jira/browse/KAFKA-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep reopened KAFKA-12416:
-
> Group Coordinator followers are failing with OffsetsOutOfOrderException
>
highluck commented on a change in pull request #9851:
URL: https://github.com/apache/kafka/pull/9851#discussion_r588027499
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java
##
@@ -59,38 +59,12 @@ public String toString() {
public s
highluck commented on a change in pull request #9851:
URL: https://github.com/apache/kafka/pull/9851#discussion_r588027499
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java
##
@@ -59,38 +59,12 @@ public String toString() {
public s
chia7712 commented on a change in pull request #9851:
URL: https://github.com/apache/kafka/pull/9851#discussion_r588025352
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java
##
@@ -59,38 +59,12 @@ public String toString() {
public s
highluck commented on a change in pull request #9851:
URL: https://github.com/apache/kafka/pull/9851#discussion_r588023830
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java
##
@@ -59,38 +59,12 @@ public String toString() {
public s
rohitrmd commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r587996458
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
##
@@ -353,11 +371,19 @@ public void setHeader
[
https://issues.apache.org/jira/browse/KAFKA-12313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295740#comment-17295740
]
Sagar Rao commented on KAFKA-12313:
---
hey [~ableegoldman], is this something that I can
chia7712 commented on a change in pull request #9851:
URL: https://github.com/apache/kafka/pull/9851#discussion_r588014280
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java
##
@@ -59,38 +59,12 @@ public String toString() {
public s
abbccdda commented on a change in pull request #10240:
URL: https://github.com/apache/kafka/pull/10240#discussion_r588010801
##
File path: tests/kafkatest/tests/core/security_test.py
##
@@ -65,7 +65,7 @@ def test_client_ssl_endpoint_validation_failure(self,
security_protocol,
vamossagar12 commented on pull request #9779:
URL: https://github.com/apache/kafka/pull/9779#issuecomment-791122717
@cadonna , could you plz review this PR as well whenevr you get the chance?
This is an automated message from
showuon opened a new pull request #10268:
URL: https://github.com/apache/kafka/pull/10268
Saw the test failed messages
[here](https://ci-builds.apache.org/job/Kafka/job/kafka-trunk-jdk11/565/testReport/junit/org.apache.kafka.connect.mirror.integration/MirrorConnectorsIntegrationTest/testRep
rohitrmd commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r587996458
##
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
##
@@ -353,11 +371,19 @@ public void setHeader
dengziming commented on pull request #10021:
URL: https://github.com/apache/kafka/pull/10021#issuecomment-791092389
Rebase onto trunk, ping @hachikuji .
This is an automated message from the Apache Git Service.
To respond to
hachikuji commented on a change in pull request #10240:
URL: https://github.com/apache/kafka/pull/10240#discussion_r587955277
##
File path: tests/kafkatest/tests/core/security_test.py
##
@@ -65,7 +65,7 @@ def test_client_ssl_endpoint_validation_failure(self,
security_protocol,
Guozhang Wang created KAFKA-12428:
-
Summary: Add a last-heartbeat-seconds-ago metric to Kafka Consumer
Key: KAFKA-12428
URL: https://issues.apache.org/jira/browse/KAFKA-12428
Project: Kafka
I
[
https://issues.apache.org/jira/browse/KAFKA-12428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-12428:
--
Component/s: streams
> Add a last-heartbeat-seconds-ago metric to Kafka Consumer
> ---
splett2 commented on pull request #10267:
URL: https://github.com/apache/kafka/pull/10267#issuecomment-791045318
cc @rajinisivaram for reviews/thoughts
This approach is fairly simple, and we still end up calling
`pollSelectionKeys()` with muted channels. An alternative that I was thi
splett2 opened a new pull request #10267:
URL: https://github.com/apache/kafka/pull/10267
`Selector.poll()` will always call `pollSelectionKeys()` for channels with
buffered data. `pollSelectionKeys()` will always update connection last idle
time, even if the channel is muted and we don't
hachikuji commented on pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#issuecomment-791038017
Well, I _was_ going to write some integration tests, but it seems we are
still awaiting some infrastructure for that. I tested it out manually and it
works correctly. I see th
wcarlson5 commented on a change in pull request #10211:
URL: https://github.com/apache/kafka/pull/10211#discussion_r587907372
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -1136,6 +1139,33 @@ public boolean commitNeeded(
hachikuji commented on pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#issuecomment-791027372
I am working on some integration tests here. Hopefully then we can wrap this
up.
This is an automated message
[
https://issues.apache.org/jira/browse/KAFKA-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-12426:
Description: As part of KIP-516, the broker should create a
partition.metadata file for ea
abbccdda commented on a change in pull request #10211:
URL: https://github.com/apache/kafka/pull/10211#discussion_r587906332
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -1136,6 +1139,33 @@ public boolean commitNeeded()
David Mao created KAFKA-12427:
-
Summary: Broker does not close muted idle connections with
buffered data
Key: KAFKA-12427
URL: https://issues.apache.org/jira/browse/KAFKA-12427
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-12426:
Issue Type: Bug (was: Improvement)
> Missing logic to create partition.metadata files in
Jason Gustafson created KAFKA-12426:
---
Summary: Missing logic to create partition.metadata files in
RaftReplicaManager
Key: KAFKA-12426
URL: https://issues.apache.org/jira/browse/KAFKA-12426
Project:
James C. McPherson created KAFKA-12425:
--
Summary: Connector status report could include a timestamp
Key: KAFKA-12425
URL: https://issues.apache.org/jira/browse/KAFKA-12425
Project: Kafka
ableegoldman commented on pull request #10251:
URL: https://github.com/apache/kafka/pull/10251#issuecomment-790998614
Merged to trunk and cherrypicked to 2.7 and 2.8 (cc @vvcephei , it's docs
only)
This is an automated messa
ableegoldman merged pull request #10251:
URL: https://github.com/apache/kafka/pull/10251
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 g
ableegoldman commented on pull request #10251:
URL: https://github.com/apache/kafka/pull/10251#issuecomment-790997202
Looks like all three Java builds passed, but some of the other builds failed
(with timeout I believe). This is a docs-only change anyway so I think it's
safe to merge
---
hachikuji merged pull request #10256:
URL: https://github.com/apache/kafka/pull/10256
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 t
wcarlson5 commented on a change in pull request #10211:
URL: https://github.com/apache/kafka/pull/10211#discussion_r587874211
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
##
@@ -3112,6 +3122,26 @@ void setChangelogOffset
[
https://issues.apache.org/jira/browse/KAFKA-12409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-12409.
Resolution: Fixed
> Leaking gauge in ReplicaManager
>
[
https://issues.apache.org/jira/browse/KAFKA-12409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12409:
---
Fix Version/s: 2.6.2
2.7.1
3.0.0
> Lea
ableegoldman commented on pull request #10260:
URL: https://github.com/apache/kafka/pull/10260#issuecomment-790990198
Cherrypicked to 2.7 and 2.6
This is an automated message from the Apache Git Service.
To respond to the mes
ableegoldman commented on pull request #10260:
URL: https://github.com/apache/kafka/pull/10260#issuecomment-790988978
Merged to trunk. Will also cherrypick to 2.7 and 2.6 since I'm still in the
process of cutting the 2.6.2 RC -- you should check with @vvcephei where we are
in the 2.8 relea
ableegoldman merged pull request #10260:
URL: https://github.com/apache/kafka/pull/10260
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 g
wcarlson5 commented on a change in pull request #10211:
URL: https://github.com/apache/kafka/pull/10211#discussion_r587869809
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -266,13 +272,13 @@ public void suspend() {
hachikuji commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r587857619
##
File path:
core/src/main/scala/kafka/server/metadata/BrokerMetadataListener.scala
##
@@ -142,28 +145,19 @@ class BrokerMetadataListener(brokerId: In
hachikuji commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r587850882
##
File path: core/src/main/scala/kafka/server/metadata/MetadataPartitions.scala
##
@@ -171,25 +200,38 @@ class MetadataPartitionsBuilder(val brokerId:
Jason Gustafson created KAFKA-12424:
---
Summary: Separate build logging in jenkins
Key: KAFKA-12424
URL: https://issues.apache.org/jira/browse/KAFKA-12424
Project: Kafka
Issue Type: Improveme
hachikuji commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r587835595
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -220,25 +220,14 @@ class KafkaRaftManager[T](
}
private def buildMetadataLo
Jason Gustafson created KAFKA-12423:
---
Summary: Consider which log configs should be overridable for the
metadata topic
Key: KAFKA-12423
URL: https://issues.apache.org/jira/browse/KAFKA-12423
Project
abbccdda commented on a change in pull request #10211:
URL: https://github.com/apache/kafka/pull/10211#discussion_r587832660
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java
##
@@ -3112,6 +3122,26 @@ void setChangelogOffsets
Max Rothman created KAFKA-12422:
---
Summary: Add getter for KafkaConsumer configs
Key: KAFKA-12422
URL: https://issues.apache.org/jira/browse/KAFKA-12422
Project: Kafka
Issue Type: Improvement
Jose Armando Garcia Sancio created KAFKA-12421:
--
Summary: Improve controller's atomic grouping
Key: KAFKA-12421
URL: https://issues.apache.org/jira/browse/KAFKA-12421
Project: Kafka
mumrah commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r587822370
##
File path: core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala
##
@@ -310,44 +288,109 @@ final class KafkaMetadataLogTest {
log.close()
-
cadonna commented on a change in pull request #10266:
URL: https://github.com/apache/kafka/pull/10266#discussion_r587817305
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeConfigsResult.java
##
@@ -36,7 +36,7 @@
private final Map> futures;
-
cadonna commented on pull request #10266:
URL: https://github.com/apache/kafka/pull/10266#issuecomment-790933530
Call for review: @mjsax @rodesai @ableegoldman @guozhangwang
This is an automated message from the Apache Git S
cadonna opened a new pull request #10266:
URL: https://github.com/apache/kafka/pull/10266
For KIP-698, we need a way to validate internal topics before
we create them. This PR adds a validation method to the
InternalTopicManager for that purpose.
### Committer Checklist (exclude
hachikuji commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-790932209
@jolshan The active segment would not be replaced during cleaning at a
minimum. I think the recovery logic we want is to scan backwards through the
`.swap` files and collect the
lostiniceland closed pull request #2882:
URL: https://github.com/apache/kafka/pull/2882
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
Iskuskov commented on a change in pull request #9541:
URL: https://github.com/apache/kafka/pull/9541#discussion_r587811360
##
File path:
connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java
##
@@ -266,10 +261,19 @@ public static void validateValue(String
Steve Rodrigues created KAFKA-12420:
---
Summary: Kafka network Selector class has many constructors; use a
Builder pattern instead
Key: KAFKA-12420
URL: https://issues.apache.org/jira/browse/KAFKA-12420
hachikuji commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r587809203
##
File path: core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala
##
@@ -310,44 +288,109 @@ final class KafkaMetadataLogTest {
log.close()
hachikuji commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r587803031
##
File path: core/src/main/scala/kafka/raft/RaftManager.scala
##
@@ -220,25 +220,14 @@ class KafkaRaftManager[T](
}
private def buildMetadataLo
jeqo opened a new pull request #10265:
URL: https://github.com/apache/kafka/pull/10265
Draft implementation of
[KIP-634](https://cwiki.apache.org/confluence/display/KAFKA/KIP-634%3A+Complementary+support+for+headers+and+record+metadata+in+Kafka+Streams+DSL)
### Committer Checklist (e
hachikuji merged pull request #10264:
URL: https://github.com/apache/kafka/pull/10264
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 t
hachikuji commented on pull request #10264:
URL: https://github.com/apache/kafka/pull/10264#issuecomment-790911623
I will merge to trunk. The metadata tests are passing locally.
This is an automated message from the Apache Gi
hachikuji opened a new pull request #10264:
URL: https://github.com/apache/kafka/pull/10264
We merged https://github.com/apache/kafka/pull/10253 and
https://github.com/apache/kafka/pull/10184 at about the same time, which caused
a build error. Topic deletions should be atomic.
### C
hachikuji commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r58995
##
File path: core/src/test/scala/kafka/raft/KafkaMetadataLogTest.scala
##
@@ -310,44 +288,109 @@ final class KafkaMetadataLogTest {
log.close()
hachikuji commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r587774537
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -297,10 +288,43 @@ final class KafkaMetadataLog private (
}
object KafkaMe
mumrah commented on a change in pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#discussion_r587767322
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -297,10 +288,43 @@ final class KafkaMetadataLog private (
}
object KafkaMetad
[
https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295547#comment-17295547
]
Matthias J. Sax commented on KAFKA-9831:
Absolutely! Reassigning.
> Failing test
[
https://issues.apache.org/jira/browse/KAFKA-9831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-9831:
--
Assignee: Luke Chen (was: Matthias J. Sax)
> Failing test:
> EosIntegrationTest.shou
hachikuji merged pull request #10184:
URL: https://github.com/apache/kafka/pull/10184
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 t
[
https://issues.apache.org/jira/browse/KAFKA-12414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep resolved KAFKA-12414.
-
Resolution: Duplicate
> Group Coordinator followers are failing with OffsetsOutOfOrderException
> --
[
https://issues.apache.org/jira/browse/KAFKA-12413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep resolved KAFKA-12413.
-
Resolution: Duplicate
> Group Coordinator followers are failing with OffsetsOutOfOrderException
> --
[
https://issues.apache.org/jira/browse/KAFKA-12416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep resolved KAFKA-12416.
-
Resolution: Duplicate
> Group Coordinator followers are failing with OffsetsOutOfOrderException
> --
[
https://issues.apache.org/jira/browse/KAFKA-12415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-12415.
-
Resolution: Fixed
> Prepare for Gradle 7.0 and restrict transitive scope for non api dependencie
[
https://issues.apache.org/jira/browse/KAFKA-12411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sandeep resolved KAFKA-12411.
-
Resolution: Duplicate
> Group Coordinator Followers failing with OutOfOrderOffsetException
> ---
ijuma merged pull request #10203:
URL: https://github.com/apache/kafka/pull/10203
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
ijuma commented on pull request #10203:
URL: https://github.com/apache/kafka/pull/10203#issuecomment-790865459
No test failures, but one of the jobs was killed in the last run:
https://ci-builds.apache.org/job/Kafka/job/kafka-pr/job/PR-10203/19/testReport/
The previous runs confir
hachikuji commented on pull request #10184:
URL: https://github.com/apache/kafka/pull/10184#issuecomment-790862249
Thanks for reviews. I will merge this on behalf of @cmccabe to trunk and 2.8.
This is an automated message fro
jolshan commented on pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#issuecomment-790855545
@hachikuji In the example above, we could also have something like `35.swap`
too, right, since we are updating the baseOffset of each segment. (Which means
we will need to look at
mumrah merged pull request #10253:
URL: https://github.com/apache/kafka/pull/10253
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
hachikuji commented on pull request #10256:
URL: https://github.com/apache/kafka/pull/10256#issuecomment-790833577
@ijuma Yes, probably. I'm working on it.
This is an automated message from the Apache Git Service.
To respond
[
https://issues.apache.org/jira/browse/KAFKA-12419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-12419:
Labels: needs-kip (was: )
> Remove Deprecated APIs of Kafka Streams in 3.0
>
ijuma commented on a change in pull request #10252:
URL: https://github.com/apache/kafka/pull/10252#discussion_r587677099
##
File path:
metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java
##
@@ -483,7 +475,7 @@ private ApiError createTopic(Creatab
1 - 100 of 174 matches
Mail list logo
