dajac commented on a change in pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#discussion_r496467056
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -1554,6 +1575,11 @@ private ConfigEntry configEntry(CreatableT
dajac commented on a change in pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#discussion_r496473270
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -733,7 +733,9 @@ public void
testCreateTopicsRetryThrottl
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496509097
##
File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json
##
@@ -0,0 +1,35 @@
+// Licensed to the Apache Software Foundation (ASF)
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496511604
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java
##
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software F
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496511864
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/FeatureMetadata.java
##
@@ -0,0 +1,111 @@
+/*
+ * Licensed to the Apache Software Founda
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496506413
##
File path: clients/src/main/resources/common/message/ApiVersionsResponse.json
##
@@ -55,8 +55,8 @@
"about": "The maximum supported version for
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496524072
##
File path: core/src/main/scala/kafka/server/BrokerFeatures.scala
##
@@ -0,0 +1,179 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496523894
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software F
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496523315
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java
##
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software F
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496523894
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/UpdateFeaturesOptions.java
##
@@ -0,0 +1,29 @@
+/*
+ * Licensed to the Apache Software F
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496524793
##
File path: core/src/main/scala/kafka/server/BrokerFeatures.scala
##
@@ -0,0 +1,179 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496525949
##
File path: core/src/main/scala/kafka/server/BrokerFeatures.scala
##
@@ -0,0 +1,179 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496526254
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,199 @@ class KafkaController(val config: KafkaConfig,
}
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496528169
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,199 @@ class KafkaController(val config: KafkaConfig,
}
}
mimaison merged pull request #9325:
URL: https://github.com/apache/kafka/pull/9325
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
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496530810
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1656,6 +1893,203 @@ class KafkaController(val config: KafkaConfig,
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496531037
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1656,6 +1893,203 @@ class KafkaController(val config: KafkaConfig,
}
mimaison commented on pull request #9325:
URL: https://github.com/apache/kafka/pull/9325#issuecomment-700540446
I'm always happy to merge improvements to the docs. Thanks for the
contribution @ankit-kumar-25
This is an auto
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496534914
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -112,8 +112,9 @@ class KafkaApis(val requestChannel: RequestChannel,
b
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496535646
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java
##
@@ -43,7 +43,7 @@
*/
public class ApiVersionsResponse e
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496538616
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/FeatureUpdate.java
##
@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundat
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496543685
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,199 @@ class KafkaController(val config: KafkaConfig,
}
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496543685
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,199 @@ class KafkaController(val config: KafkaConfig,
}
}
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496543685
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -272,6 +281,199 @@ class KafkaController(val config: KafkaConfig,
}
}
dajac commented on pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#issuecomment-700557270
@rajinisivaram Thanks for your comments. I have updated the PR.
This is an automated message from the Apache Git Ser
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496550557
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java
##
@@ -40,14 +40,16 @@ public static FinalizedVersionRange f
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496550557
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java
##
@@ -40,14 +40,16 @@ public static FinalizedVersionRange f
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496550557
##
File path:
clients/src/main/java/org/apache/kafka/common/feature/FinalizedVersionRange.java
##
@@ -40,14 +40,16 @@ public static FinalizedVersionRange f
kowshik commented on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-700585584
@junrao Thanks a lot for the review! I've addressed the comments in the
recent commit: 06d8b47131f168db88e4f7d5bda3dd025ba9a2a2.
-
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496509097
##
File path: clients/src/main/resources/common/message/UpdateFeaturesRequest.json
##
@@ -0,0 +1,35 @@
+// Licensed to the Apache Software Foundation (ASF)
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496509282
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/DescribeFeaturesOptions.java
##
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software
kowshik commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496511604
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java
##
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software F
rajinisivaram commented on a change in pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#discussion_r496579003
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -1554,6 +1575,13 @@ private ConfigEntry configEntry(Cr
kowshik edited a comment on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-700585584
@junrao Thanks a lot for the review! I've addressed the comments in the
recent commit: 06d8b47131f168db88e4f7d5bda3dd025ba9a2a2. I've provided a
response to all of your com
dajac commented on a change in pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#discussion_r496645598
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
##
@@ -1554,6 +1575,13 @@ private ConfigEntry configEntry(CreatableT
dajac commented on pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#issuecomment-700644563
@rajinisivaram Thanks for your suggestion. I have updated the PR.
This is an automated message from the Apache Git S
rajinisivaram commented on pull request #9345:
URL: https://github.com/apache/kafka/pull/9345#issuecomment-700664402
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, plea
nizhikov commented on a change in pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#discussion_r496670159
##
File path: tests/docker/Dockerfile
##
@@ -32,9 +32,11 @@ ARG ducker_creator=default
LABEL ducker.creator=$ducker_creator
# Update Linux and install
rajinisivaram commented on pull request #9344:
URL: https://github.com/apache/kafka/pull/9344#issuecomment-700735225
Builds are good, merging to trunk.
This is an automated message from the Apache Git Service.
To respond to t
rajinisivaram merged pull request #9344:
URL: https://github.com/apache/kafka/pull/9344
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 #8181:
URL: https://github.com/apache/kafka/pull/8181#issuecomment-700766402
Cherry-picked to 2.4 as well.
This is an automated message from the Apache Git Service.
To respond to the message
[
https://issues.apache.org/jira/browse/KAFKA-9584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-9584:
Fix Version/s: 2.4.2
> Removing headers causes ConcurrentModificationException
> --
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-700766947
Hello, @guozhangwang , @mimaison
The only thing we need to have perfect merge is ducktape release that
contains python3 fixes.
Can we go with the current PR, which poin
vvcephei commented on a change in pull request #9020:
URL: https://github.com/apache/kafka/pull/9020#discussion_r496796429
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/WrappingStoreProvider.java
##
@@ -46,11 +46,22 @@ public void setStoreQueryPa
[
https://issues.apache.org/jira/browse/KAFKA-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-9514.
Fix Version/s: 2.7.0
Resolution: Fixed
> The protocol generator generated useless condition
[
https://issues.apache.org/jira/browse/KAFKA-9546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9546.
--
Resolution: Won't Fix
I'm going to close this as WONTFIX, per my previous comment.
> Make File
rhauch closed pull request #8134:
URL: https://github.com/apache/kafka/pull/8134
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
rhauch commented on pull request #8134:
URL: https://github.com/apache/kafka/pull/8134#issuecomment-700796780
Thanks for the PR, @gcsaba2. However, I'm going to close this per my
comments on https://issues.apache.org/jira/browse/KAFKA-9546.
TLDR; the `FileStreamSourceConnector` clas
kowshik edited a comment on pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#issuecomment-700585584
@junrao Thanks a lot for the review! I've addressed the comments in the
recent commit: 06d8b47131f168db88e4f7d5bda3dd025ba9a2a2. I've provided a
response to all of your com
edenhill commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-700817177
We'll want to use a released version of ducktape to get stable tests. I'm
working on getting a ducktape release out.
Jason Gustafson created KAFKA-10533:
---
Summary: Add log flush semantics to simulation test
Key: KAFKA-10533
URL: https://issues.apache.org/jira/browse/KAFKA-10533
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-10533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-10533:
Description: In order to do KAFKA-10526, it is useful to add support for
flush semantics t
linenwei created KAFKA-10534:
Summary: Modify the originals parameter type of the AbstractConfig
class to avoid redundant judgments in the code
Key: KAFKA-10534
URL: https://issues.apache.org/jira/browse/KAFKA-10534
[
https://issues.apache.org/jira/browse/KAFKA-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linenwei updated KAFKA-10534:
-
Flags: Patch
Description:
Source Code:
{code:java}
@SuppressWarnings("unchecked")
publi
[
https://issues.apache.org/jira/browse/KAFKA-10534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
linenwei updated KAFKA-10534:
-
Summary: Modify the AbstractConfig class, convert parameter `originals`
type from Map to Map to avoid
chia7712 commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496904812
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +133,14 @@ public void start() {
List
abbccdda commented on a change in pull request #9001:
URL: https://github.com/apache/kafka/pull/9001#discussion_r496901588
##
File path:
clients/src/main/java/org/apache/kafka/clients/admin/FinalizedVersionRange.java
##
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software
kobebryantlin0 opened a new pull request #9350:
URL: https://github.com/apache/kafka/pull/9350
Modify the AbstractConfig class, convert params `originals` type from Map to Map to avoid redundant judgments in the code.
### Committer Checklist (excluded from commit message)
- [ ] Ver
leosilvadev opened a new pull request #9351:
URL: https://github.com/apache/kafka/pull/9351
There is a JIRA ticket requesting this small change
(https://issues.apache.org/jira/browse/KAFKA-10047)
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implem
John Roesler created KAFKA-10535:
Summary: KIP-478: Implement StateStoreContext and Record
Key: KAFKA-10535
URL: https://issues.apache.org/jira/browse/KAFKA-10535
Project: Kafka
Issue Type: S
John Roesler created KAFKA-10536:
Summary: KIP-478: Implement KStream changes
Key: KAFKA-10536
URL: https://issues.apache.org/jira/browse/KAFKA-10536
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10537:
Summary: Convert KStreamImpl filters to new PAPI
Key: KAFKA-10537
URL: https://issues.apache.org/jira/browse/KAFKA-10537
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10538:
Summary: Convert KStreamImpl maps to new PAPI
Key: KAFKA-10538
URL: https://issues.apache.org/jira/browse/KAFKA-10538
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10539:
Summary: Convert KStreamImpl joins to new PAPI
Key: KAFKA-10539
URL: https://issues.apache.org/jira/browse/KAFKA-10539
Project: Kafka
Issue Type: Sub-task
ahuang98 commented on pull request #9340:
URL: https://github.com/apache/kafka/pull/9340#issuecomment-700886220
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-10539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10539:
Assignee: John Roesler
> Convert KStreamImpl joins to new PAPI
>
John Roesler created KAFKA-10540:
Summary: Convert KStream aggregations to new PAPI
Key: KAFKA-10540
URL: https://issues.apache.org/jira/browse/KAFKA-10540
Project: Kafka
Issue Type: Sub-task
ahuang98 removed a comment on pull request #9340:
URL: https://github.com/apache/kafka/pull/9340#issuecomment-700886220
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, p
John Roesler created KAFKA-10541:
Summary: Convert KTable filters to new PAPI
Key: KAFKA-10541
URL: https://issues.apache.org/jira/browse/KAFKA-10541
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10543:
Summary: Convert KTable joins to new PAPI
Key: KAFKA-10543
URL: https://issues.apache.org/jira/browse/KAFKA-10543
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10544:
Summary: Convert KTable aggregations to new PAPI
Key: KAFKA-10544
URL: https://issues.apache.org/jira/browse/KAFKA-10544
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10542:
Summary: Convert KTable maps to new PAPI
Key: KAFKA-10542
URL: https://issues.apache.org/jira/browse/KAFKA-10542
Project: Kafka
Issue Type: Sub-task
John Roesler created KAFKA-10546:
Summary: KIP-478: Deprecate old PAPI
Key: KAFKA-10546
URL: https://issues.apache.org/jira/browse/KAFKA-10546
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-10540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10540:
Assignee: John Roesler
> Convert KStream aggregations to new PAPI
> -
[
https://issues.apache.org/jira/browse/KAFKA-10544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10544:
Assignee: John Roesler
> Convert KTable aggregations to new PAPI
> --
[
https://issues.apache.org/jira/browse/KAFKA-10543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10543:
Assignee: John Roesler
> Convert KTable joins to new PAPI
> -
Justine Olshan created KAFKA-10545:
--
Summary: Create Topic IDs and Propagate to Brokers
Key: KAFKA-10545
URL: https://issues.apache.org/jira/browse/KAFKA-10545
Project: Kafka
Issue Type: Imp
[
https://issues.apache.org/jira/browse/KAFKA-10542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10542:
Assignee: John Roesler
> Convert KTable maps to new PAPI
> --
[
https://issues.apache.org/jira/browse/KAFKA-10437?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10437:
-
Summary: KIP-478: Implement test-utils changes (was: Convert test-utils
(and StateStore) for KI
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-8872:
--
Description:
Kafka currently uniquely identifies a topic by its name. This is generally
suffic
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-8872:
--
Description:
Kafka currently uniquely identifies a topic by its name. This is generally
suffic
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-8872:
--
Description:
Kafka currently uniquely identifies a topic by its name. This is generally
suffic
[
https://issues.apache.org/jira/browse/KAFKA-10545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-10545:
---
Parent: KAFKA-8872
Issue Type: Sub-task (was: Improvement)
> Create Topic IDs and P
[
https://issues.apache.org/jira/browse/KAFKA-8872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan updated KAFKA-8872:
--
Description:
Kafka currently uniquely identifies a topic by its name. This is generally
suffic
Justine Olshan created KAFKA-10547:
--
Summary: Add topic IDs to MetadataResponse, UpdateMetadata, and
Fetch
Key: KAFKA-10547
URL: https://issues.apache.org/jira/browse/KAFKA-10547
Project: Kafka
Justine Olshan created KAFKA-10548:
--
Summary: Implement Type field and logic for LeaderAndIsrRequests
Key: KAFKA-10548
URL: https://issues.apache.org/jira/browse/KAFKA-10548
Project: Kafka
I
Justine Olshan created KAFKA-10549:
--
Summary: Add topic ID support to DeleteTopics,ListOffsets,
OffsetForLeaders, StopReplica
Key: KAFKA-10549
URL: https://issues.apache.org/jira/browse/KAFKA-10549
P
Justine Olshan created KAFKA-10550:
--
Summary: Update kafka-topics.sh to support Topic IDs
Key: KAFKA-10550
URL: https://issues.apache.org/jira/browse/KAFKA-10550
Project: Kafka
Issue Type: S
chia7712 commented on pull request #9284:
URL: https://github.com/apache/kafka/pull/9284#issuecomment-700904592
@hachikuji Thanks for reviews and update!
This is an automated message from the Apache Git Service.
To respond to
hachikuji opened a new pull request #9352:
URL: https://github.com/apache/kafka/pull/9352
This patch adds missing flush logic to `KafkaRaftClient`. The initial
flushing behavior is simplistic. We guarantee that the leader will not
replicate above the last flushed offset and we guarantee th
nizhikov commented on pull request #9196:
URL: https://github.com/apache/kafka/pull/9196#issuecomment-700910936
@edenhill Thanks for the help! Appreciate it
This is an automated message from the Apache Git Service.
To respond
hachikuji merged pull request #9284:
URL: https://github.com/apache/kafka/pull/9284
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
[
https://issues.apache.org/jira/browse/KAFKA-10479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-10479.
-
Fix Version/s: 2.7.0
Resolution: Fixed
> Throw exception if users try to update c
Justine Olshan created KAFKA-10551:
--
Summary: Support topic IDs in Produce request
Key: KAFKA-10551
URL: https://issues.apache.org/jira/browse/KAFKA-10551
Project: Kafka
Issue Type: Sub-task
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r496983721
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +133,14 @@ public void start() {
Lis
Justine Olshan created KAFKA-10552:
--
Summary: Update directory structure to use topic IDs
Key: KAFKA-10552
URL: https://issues.apache.org/jira/browse/KAFKA-10552
Project: Kafka
Issue Type: S
chia7712 commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r497017395
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +133,14 @@ public void start() {
List
[
https://issues.apache.org/jira/browse/KAFKA-10510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Rżysko reassigned KAFKA-10510:
Assignee: Piotr Rżysko
> Reassigning partitions should not allow increasing RF of a parti
scanterog commented on a change in pull request #9313:
URL: https://github.com/apache/kafka/pull/9313#discussion_r495871017
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -199,8 +199,8 @@
protected static fina
soondenana commented on a change in pull request #9347:
URL: https://github.com/apache/kafka/pull/9347#discussion_r497034435
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java
##
@@ -133,11 +133,14 @@ public void start() {
Lis
1 - 100 of 124 matches
Mail list logo
