hachikuji commented on pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#issuecomment-730001511
cc @chia7712 @dajac
This is an automated message from the Apache Git Service.
To respond to the message, please
rajinisivaram commented on pull request #9473:
URL: https://github.com/apache/kafka/pull/9473#issuecomment-730006469
@jolshan Thanks for the updates, merging to trunk.
This is an automated message from the Apache Git Service.
rajinisivaram merged pull request #9473:
URL: https://github.com/apache/kafka/pull/9473
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
ableegoldman commented on a change in pull request #9487:
URL: https://github.com/apache/kafka/pull/9487#discussion_r526477258
##
File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java
##
@@ -932,56 +1028,62 @@ public synchronized boolean close(final long t
[
https://issues.apache.org/jira/browse/KAFKA-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235061#comment-17235061
]
Lucas Wang commented on KAFKA-10734:
Thanks for your reply [~junrao]. In some cluste
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10500:
Labels: kip (was: needs-kip)
> Add API to Start and Stop Stream Threads
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10500:
Description:
Currently, there is no possibility in Kafka Streams to increase or decrease t
mjsax merged pull request #9572:
URL: https://github.com/apache/kafka/pull/9572
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
mjsax commented on pull request #9572:
URL: https://github.com/apache/kafka/pull/9572#issuecomment-730028264
Thanks for the PR @wcarlson5. Merged to `trunk`.
This is an automated message from the Apache Git Service.
To respon
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-10500.
-
Fix Version/s: 2.8.0
Resolution: Fixed
> Add API to Start and Stop Stream Threads
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10015:
Labels: kip (was: needs-kip)
> React Smartly to Unexpected Errors on Stream Threads
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10015:
Description:
Currently, if an unexpected error occurs on a stream thread, the stream threa
[
https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-6943.
---
Resolution: Fixed
> Have option to shutdown KS cleanly if any threads crashes
[
https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-6943:
--
Fix Version/s: 2.8.0
> Have option to shutdown KS cleanly if any threads crashe
[
https://issues.apache.org/jira/browse/KAFKA-6943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235069#comment-17235069
]
A. Sophie Blee-Goldman commented on KAFKA-6943:
---
Resolved via https://githu
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-4748:
--
Fix Version/s: 2.8.0
> Need a way to shutdown all workers in a Streams applicat
[
https://issues.apache.org/jira/browse/KAFKA-10500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reopened KAFKA-10500:
> Add API to Start and Stop Stream Threads
> -
[
https://issues.apache.org/jira/browse/KAFKA-4748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman resolved KAFKA-4748.
---
Resolution: Fixed
> Need a way to shutdown all workers in a Streams applicati
abbccdda commented on a change in pull request #9617:
URL: https://github.com/apache/kafka/pull/9617#discussion_r526499505
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -974,21 +969,6 @@ private void handleInitiateApiVersionRequests(long
rajinisivaram commented on a change in pull request #9485:
URL: https://github.com/apache/kafka/pull/9485#discussion_r526479473
##
File path:
clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java
##
@@ -139,4 +150,129 @@
* @return Iterator for ACL bind
[
https://issues.apache.org/jira/browse/KAFKA-9672?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-9672:
-
Assignee: Jose Armando Garcia Sancio
> Dead brokers in ISR cause
hachikuji commented on a change in pull request #9547:
URL: https://github.com/apache/kafka/pull/9547#discussion_r526509285
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochRequest.java
##
@@ -51,169 +47,120 @@
*/
public stat
hachikuji commented on pull request #9547:
URL: https://github.com/apache/kafka/pull/9547#issuecomment-730040680
@dajac The updates LGTM.
This is an automated message from the Apache Git Service.
To respond to the message, pl
mjsax merged pull request #9570:
URL: https://github.com/apache/kafka/pull/9570
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
anatasiavela commented on a change in pull request #9526:
URL: https://github.com/apache/kafka/pull/9526#discussion_r526511067
##
File path: core/src/main/scala/kafka/network/RequestConvertToJson.scala
##
@@ -0,0 +1,362 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF
abbccdda closed pull request #9042:
URL: https://github.com/apache/kafka/pull/9042
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
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526525212
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1476,33 +1650,36 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metri
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526527000
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1324,7 +1404,60 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metric
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526527000
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1324,7 +1404,60 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metric
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526527000
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1324,7 +1404,60 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metric
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526528689
##
File path: core/src/test/scala/unit/kafka/network/ConnectionQuotasTest.scala
##
@@ -633,18 +837,27 @@ class ConnectionQuotasTest {
David Mao created KAFKA-10744:
-
Summary: Listener and broker connection rate quota tests should
use mock time
Key: KAFKA-10744
URL: https://issues.apache.org/jira/browse/KAFKA-10744
Project: Kafka
splett2 commented on a change in pull request #9386:
URL: https://github.com/apache/kafka/pull/9386#discussion_r526525212
##
File path: core/src/main/scala/kafka/network/SocketServer.scala
##
@@ -1476,33 +1650,36 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metri
chia7712 commented on pull request #9547:
URL: https://github.com/apache/kafka/pull/9547#issuecomment-730094552
@dajac +1 to nice updating. sorry that my commit causes conflicting files to
you.
This is an automated message f
chia7712 commented on a change in pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#discussion_r526567417
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
##
@@ -130,13 +139,25 @@ public void writeVarlong(long i) {
*/
chia7712 merged pull request #9507:
URL: https://github.com/apache/kafka/pull/9507
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
chia7712 commented on pull request #9507:
URL: https://github.com/apache/kafka/pull/9507#issuecomment-730104149
@showuon Thanks for this patch!
This is an automated message from the Apache Git Service.
To respond to the messa
ijuma commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r526570690
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1749,6 +1752,9 @@ class Log(@volatile private var _dir: File,
checkIfMemoryMappedBuffe
ijuma commented on a change in pull request #9590:
URL: https://github.com/apache/kafka/pull/9590#discussion_r526571061
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1749,6 +1752,9 @@ class Log(@volatile private var _dir: File,
checkIfMemoryMappedBuffe
hachikuji commented on pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#issuecomment-730107392
@chia7712 To be honest, I'm not sure. I think it makes sense in general to
try and batch the writes together to reduce number of calls to the kernel in
any case, but I am not su
chia7712 commented on a change in pull request #9617:
URL: https://github.com/apache/kafka/pull/9617#discussion_r526577116
##
File path: core/src/main/scala/kafka/server/ForwardingManager.scala
##
@@ -17,25 +17,17 @@
package kafka.server
-import kafka.metrics.KafkaMetricsG
NAYUSIK created KAFKA-10745:
---
Summary: Please let me know how I check the time which Source
connector receive the data from source table.
Key: KAFKA-10745
URL: https://issues.apache.org/jira/browse/KAFKA-10745
hachikuji commented on a change in pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#discussion_r526583778
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
##
@@ -39,6 +42,7 @@
*/
public class SendBuilder implements Writ
hachikuji commented on a change in pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#discussion_r526584156
##
File path:
clients/src/main/java/org/apache/kafka/common/protocol/SendBuilder.java
##
@@ -130,13 +139,25 @@ public void writeVarlong(long i) {
*
chia7712 commented on pull request #9619:
URL: https://github.com/apache/kafka/pull/9619#issuecomment-730134289
+1 to last commit
This is an automated message from the Apache Git Service.
To respond to the message, please log
chia7712 opened a new pull request #9620:
URL: https://github.com/apache/kafka/pull/9620
Except for LazyDownConversionRecords, we don't use the generic. We should
handle the specify case directly instead of making generic in whole project.
In short, this patch is a kind of cleanup.
chia7712 commented on a change in pull request #9435:
URL: https://github.com/apache/kafka/pull/9435#discussion_r526616584
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1333,7 +1343,17 @@ class KafkaApis(val requestChannel: RequestChannel,
}
chia7712 commented on pull request #9204:
URL: https://github.com/apache/kafka/pull/9204#issuecomment-730154806
rebase patch to trigger QA
This is an automated message from the Apache Git Service.
To respond to the message,
101 - 148 of 148 matches
Mail list logo
