yingquan he created KAFKA-13871:
---
Summary: The documentation for the configuration item
QUORUM_FETCH_TIMEOUT of the RaftConfig class is incorrect
Key: KAFKA-13871
URL: https://issues.apache.org/jira/browse/KAFKA-138
Francois Visconte created KAFKA-13872:
-
Summary: Partitions are truncated when leader is replaced
Key: KAFKA-13872
URL: https://issues.apache.org/jira/browse/KAFKA-13872
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-13872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Francois Visconte updated KAFKA-13872:
--
Description:
Sample setup:
* a topic with one partition and RF=3
* a producer using
vamossagar12 commented on code in PR #12104:
URL: https://github.com/apache/kafka/pull/12104#discussion_r865051847
##
core/src/test/scala/integration/kafka/admin/TopicCommandIntegrationTest.scala:
##
@@ -733,12 +733,18 @@ class TopicCommandIntegrationTest extends
KafkaServerTes
[
https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13870:
Labels: needs-kip (was: )
> support both Suppressed untilTimeLimit and maxBytes without u
[
https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531836#comment-17531836
]
Matthias J. Sax commented on KAFKA-13870:
-
I think you mix up two concepts: wind
vamossagar12 commented on PR #11211:
URL: https://github.com/apache/kafka/pull/11211#issuecomment-1117583307
> LGTM! Thanks for the PR and, the patience! @ableegoldman @guozhangwang
@mjsax , do you want to have another look for this PR?
hi.. whenever you get the chance, could you plz
guozhangwang merged PR #11874:
URL: https://github.com/apache/kafka/pull/11874
--
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: jira-unsubscr...@kafka.ap
hachikuji merged PR #12106:
URL: https://github.com/apache/kafka/pull/12106
--
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: jira-unsubscr...@kafka.apach
vamossagar12 opened a new pull request, #12121:
URL: https://github.com/apache/kafka/pull/12121
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of te
Jim Hughes created KAFKA-13873:
--
Summary: Add ability to Pause / Resume KafkaStreams Topologies
Key: KAFKA-13873
URL: https://issues.apache.org/jira/browse/KAFKA-13873
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes reassigned KAFKA-13873:
--
Assignee: Jim Hughes
> Add ability to Pause / Resume KafkaStreams Topologies
> --
guozhangwang commented on PR #12041:
URL: https://github.com/apache/kafka/pull/12041#issuecomment-1117635812
Thanks @C0urante for your thoughts. I'd like to clarify one thing that,
today users can pass in both defined and unknown config values, where the
latter may be used in some plugin mo
[
https://issues.apache.org/jira/browse/KAFKA-13861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Akhilesh Chaganti resolved KAFKA-13861.
---
Resolution: Fixed
> validateOnly request field does not work for CreatePartition req
[
https://issues.apache.org/jira/browse/KAFKA-13861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-13861:
Fix Version/s: 3.3.0
> validateOnly request field does not work for CreatePartition reques
cmccabe commented on PR #12109:
URL: https://github.com/apache/kafka/pull/12109#issuecomment-1117657256
We already validate that topic configurations can't be null in
`ControllerConfigurationValidator`.
```
override def validate(
resource: ConfigResource,
config: ut
[
https://issues.apache.org/jira/browse/KAFKA-13863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17531880#comment-17531880
]
Colin McCabe commented on KAFKA-13863:
--
We already validate that topic configuratio
Ge opened a new pull request, #12122:
URL: https://github.com/apache/kafka/pull/12122
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
*Summary of testing
akhileshchg commented on code in PR #12108:
URL: https://github.com/apache/kafka/pull/12108#discussion_r865146433
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -1751,13 +1777,32 @@ class PlaintextAdminIntegrationTest extends
BaseAdminIn
junrao merged PR #12029:
URL: https://github.com/apache/kafka/pull/12029
--
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: jira-unsubscr...@kafka.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-13815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao resolved KAFKA-13815.
-
Fix Version/s: 3.3.0
Resolution: Fixed
merged the PR to trunk
> Avoid reinitialization for a rep
ahuang98 opened a new pull request, #12123:
URL: https://github.com/apache/kafka/pull/12123
From https://github.com/apache/kafka/pull/12050:
> This patch includes a new metadata.version which is planned to replace IBP
in KRaft clusters as specified in KIP-778. The kafka-storage tool n
hachikuji commented on code in PR #12108:
URL: https://github.com/apache/kafka/pull/12108#discussion_r865377321
##
metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java:
##
@@ -215,13 +215,17 @@ private void
incrementalAlterConfigResource(ConfigRes
artemlivshits commented on code in PR #12049:
URL: https://github.com/apache/kafka/pull/12049#discussion_r865302205
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -960,8 +1002,10 @@ private Future doSend(ProducerRecord record, Callback call
artemlivshits commented on PR #12049:
URL: https://github.com/apache/kafka/pull/12049#issuecomment-1117971682
Hmm, for some reason the update didn't trigger any build & test jobs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHu
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13873:
Component/s: streams
> Add ability to Pause / Resume KafkaStreams Topologies
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13873:
Labels: kip (was: )
> Add ability to Pause / Resume KafkaStreams Topologies
> ---
[
https://issues.apache.org/jira/browse/KAFKA-13873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-13873:
Description:
In order to reduce resources used or modify data pipelines, users may want to
hachikuji commented on code in PR #11969:
URL: https://github.com/apache/kafka/pull/11969#discussion_r865430367
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1864,6 +1780,18 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metrics: Metrics) extend
cmccabe commented on code in PR #11969:
URL: https://github.com/apache/kafka/pull/11969#discussion_r865495566
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -906,12 +906,35 @@ private void appendRaftEvent(String name, Runnable
runnable) {
cmccabe commented on code in PR #11969:
URL: https://github.com/apache/kafka/pull/11969#discussion_r865495994
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -104,184 +103,141 @@ class SocketServer(val config: KafkaConfig,
private[this] val nextProcessorId: A
Colin McCabe created KAFKA-13874:
Summary: Avoid synchronization in SocketServer metrics
Key: KAFKA-13874
URL: https://issues.apache.org/jira/browse/KAFKA-13874
Project: Kafka
Issue Type: Imp
cmccabe commented on code in PR #11969:
URL: https://github.com/apache/kafka/pull/11969#discussion_r865496509
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -104,184 +103,141 @@ class SocketServer(val config: KafkaConfig,
private[this] val nextProcessorId: A
cmccabe commented on code in PR #11969:
URL: https://github.com/apache/kafka/pull/11969#discussion_r865499094
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1864,6 +1780,18 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metrics: Metrics) extend
dengziming commented on code in PR #12104:
URL: https://github.com/apache/kafka/pull/12104#discussion_r865512959
##
core/src/test/scala/integration/kafka/admin/TopicCommandIntegrationTest.scala:
##
@@ -733,12 +733,18 @@ class TopicCommandIntegrationTest extends
KafkaServerTestH
[
https://issues.apache.org/jira/browse/KAFKA-13872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17532002#comment-17532002
]
Luke Chen commented on KAFKA-13872:
---
[~fvisconte] , thanks for reporting the issue. Bu
dengziming commented on code in PR #12104:
URL: https://github.com/apache/kafka/pull/12104#discussion_r865512959
##
core/src/test/scala/integration/kafka/admin/TopicCommandIntegrationTest.scala:
##
@@ -733,12 +733,18 @@ class TopicCommandIntegrationTest extends
KafkaServerTestH
dengziming commented on PR #12112:
URL: https://github.com/apache/kafka/pull/12112#issuecomment-1118110191
@showuon I seem to see it failed but I can't find it anymore, I will close
this after I can't see it fail again in a few days.
@divijvaidya I would fix your comment if this test real
[
https://issues.apache.org/jira/browse/KAFKA-13875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13875:
--
Labels: newbie (was: )
> update docs to include topoicId for kafka-topics.sh --describe output
>
Luke Chen created KAFKA-13875:
-
Summary: update docs to include topoicId for kafka-topics.sh
--describe output
Key: KAFKA-13875
URL: https://issues.apache.org/jira/browse/KAFKA-13875
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-13875:
--
Description:
The topic describe output in quickstart doc here:
[https://kafka.apache.org/quickstart]
dengziming commented on code in PR #12108:
URL: https://github.com/apache/kafka/pull/12108#discussion_r865580075
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -1751,13 +1777,32 @@ class PlaintextAdminIntegrationTest extends
BaseAdminInt
dengziming commented on code in PR #12108:
URL: https://github.com/apache/kafka/pull/12108#discussion_r865581359
##
metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java:
##
@@ -215,13 +215,17 @@ private void
incrementalAlterConfigResource(ConfigRe
dengziming commented on PR #12108:
URL: https://github.com/apache/kafka/pull/12108#issuecomment-1118210953
Thank you for your suggestions @hachikuji @akhileshchg, PTAL again when you
have time.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
44 matches
Mail list logo