[
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
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
[
https://issues.apache.org/jira/browse/KAFKA-13872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17532002#comment-17532002
]
Luke Chen commented on KAFKA-13872:
---
[~fvisconte] , thanks for reporting the issue. But I think this
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
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:
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:
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:
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
[
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
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
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
[
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
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:
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
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=17531880#comment-17531880
]
Colin McCabe commented on KAFKA-13863:
--
We already validate that topic configurations can't be null
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:
[
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
[
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
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
[
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
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
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:
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-13870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17531836#comment-17531836
]
Matthias J. Sax commented on KAFKA-13870:
-
I think you mix up two concepts: windowing is about
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
[
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
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:
41 matches
Mail list logo
