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
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 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
[
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]
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:
--
Labels: newbie (was: )
> update docs to include topoicId for kafka-topics.sh --describe output
>
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
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
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
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
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_r865495994
##
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_r865495566
##
metadata/src/main/java/org/apache/kafka/controller/QuorumController.java:
##
@@ -906,12 +906,35 @@ private void appendRaftEvent(String name, Runnable
runnable) {
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
[
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
[
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
> ---
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
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
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
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
[
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
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
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
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
[
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
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-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
[
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
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-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
> --
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:
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
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
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
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
[
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 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-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
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
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
44 matches
Mail list logo
