[
https://issues.apache.org/jira/browse/KAFKA-13927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585652#comment-17585652
]
Jordan Bull commented on KAFKA-13927:
-
I've also encountered this. This is especiall
jordanbull opened a new pull request, #12566:
URL: https://github.com/apache/kafka/pull/12566
Only clear origOffsets when clearing the messageBatch. Prior to this change,
origOffsets is cleared at the start of each convertMessages call in which all
newly polled messages are added to origOff
jsancio opened a new pull request, #12565:
URL: https://github.com/apache/kafka/pull/12565
The boostrap.checkpoint files should include a control record batch for
the SnapshotHeaderRecord at the start of the file. It should also
include a control record batch for the SnapshotFooterRecor
jolshan commented on PR #12564:
URL: https://github.com/apache/kafka/pull/12564#issuecomment-1229050542
@showuon here's a cleanup PR :)
--
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 specif
jolshan commented on code in PR #12501:
URL: https://github.com/apache/kafka/pull/12501#discussion_r956504779
##
core/src/test/scala/other/kafka/StressTestLog.scala:
##
@@ -50,7 +50,7 @@ object StressTestLog {
time = time,
maxTransactionTimeoutMs = 5 * 60 * 1000,
jolshan opened a new pull request, #12564:
URL: https://github.com/apache/kafka/pull/12564
As per Luke's comments in https://github.com/apache/kafka/pull/12501, I
added the correct name and removed the hard coded values for the config in
tests.
### Committer Checklist (excluded from
AlanConfluent commented on PR #12458:
URL: https://github.com/apache/kafka/pull/12458#issuecomment-1229038305
I think this was the ultimate run which covered everything under streams:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/system-test-kafka-br
vvcephei merged PR #12458:
URL: https://github.com/apache/kafka/pull/12458
--
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
wcarlson5 commented on code in PR #12562:
URL: https://github.com/apache/kafka/pull/12562#discussion_r956444131
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -86,6 +87,10 @@ public boolean onlyStandbyTasksLeft() {
jeffkbkim commented on PR #12563:
URL: https://github.com/apache/kafka/pull/12563#issuecomment-1228950795
thanks for the PR. looks good to me
--
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 s
vvcephei commented on PR #12458:
URL: https://github.com/apache/kafka/pull/12458#issuecomment-1228950450
It looks like you have a green run:
http://confluent-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/system-test-kafka-branch-builder--1661474350--AlanConfluent--updat
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585595#comment-17585595
]
Nicholas Telford edited comment on KAFKA-10635 at 8/26/22 7:28 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585595#comment-17585595
]
Nicholas Telford commented on KAFKA-10635:
--
Hi [~guozhang], there's not really
dajac opened a new pull request, #12563:
URL: https://github.com/apache/kafka/pull/12563
Mainly rename `addPartitionOwnership` to `addOwnedPartition` in order to be
consistent with `addLoadingPartition`.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
[
https://issues.apache.org/jira/browse/KAFKA-14179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-14179:
--
Assignee: Colin McCabe
> Improve docs/upgrade.html to talk ab
wangwalton closed pull request #9993: Schema Exception Interface fix
URL: https://github.com/apache/kafka/pull/9993
--
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 unsubscri
[
https://issues.apache.org/jira/browse/KAFKA-14183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio reassigned KAFKA-14183:
--
Assignee: Jose Armando Garcia Sancio (was: Jason Gustafson)
dajac commented on PR #12559:
URL: https://github.com/apache/kafka/pull/12559#issuecomment-1228654632
I am not sure about it. In highly loaded system with a lot of connections,
this will result in flooding the logs. This is even worst if there are rogue
clients. It would be better to rely o
vamossagar12 commented on PR #12561:
URL: https://github.com/apache/kafka/pull/12561#issuecomment-1228640137
In this PR, similar to Luke's PR, I have added the condition to do a
revoking rebalance consecutively. The only difference is that whether
revocation would happen or not is decided b
vamossagar12 commented on PR #12485:
URL: https://github.com/apache/kafka/pull/12485#issuecomment-1228623886
> @vamossagar12 It's easier to comment on proposed changes when they're
implemented as code; if you can put together a draft of your proposal (feeling
free to note any open questions
C0urante commented on PR #12485:
URL: https://github.com/apache/kafka/pull/12485#issuecomment-1228590461
@vamossagar12 It's easier to comment on proposed changes when they're
implemented as code; if you can put together a draft of your proposal (feeling
free to note any open questions or pa
[
https://issues.apache.org/jira/browse/KAFKA-14180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585411#comment-17585411
]
Chris Egerton edited comment on KAFKA-14180 at 8/26/22 2:33 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-14180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton resolved KAFKA-14180.
---
Resolution: Invalid
"Not a bug" doesn't seem quite accurate for some reason...
> Help, I've
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390
]
Yash Mayya edited comment on KAFKA-14015 at 8/26/22 2:02 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390
]
Yash Mayya edited comment on KAFKA-14015 at 8/26/22 2:00 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585390#comment-17585390
]
Yash Mayya commented on KAFKA-14015:
In essence, this should work as expected when C
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585384#comment-17585384
]
Yash Mayya commented on KAFKA-14015:
Hm this looks like it maybe a bug in the Standa
[
https://issues.apache.org/jira/browse/KAFKA-14185?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gabriel Giussi updated KAFKA-14185:
---
Description:
We were incorrectly getting a reference to ConsumerGroupMetadata before the
fi
C0urante commented on PR #12561:
URL: https://github.com/apache/kafka/pull/12561#issuecomment-1228504571
Thanks @vamossagar12. I haven't looked too closely at the code yet but have
a couple high-level thoughts:
1. We should not introduce a backoff delay the first time a new worker joi
ijuma commented on code in PR #12230:
URL: https://github.com/apache/kafka/pull/12230#discussion_r956053947
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -463,8 +463,7 @@ public static T newParameterizedInstance(String
className, Object... params)
Gabriel Giussi created KAFKA-14185:
--
Summary: Broker allows transactions with generation.id -1 and
could lead to duplicates
Key: KAFKA-14185
URL: https://issues.apache.org/jira/browse/KAFKA-14185
Pro
C0urante commented on code in PR #12478:
URL: https://github.com/apache/kafka/pull/12478#discussion_r956045554
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java:
##
@@ -175,9 +179,8 @@ protected V execAndRetry(Operation ope
C0urante commented on code in PR #12478:
URL: https://github.com/apache/kafka/pull/12478#discussion_r956044683
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java:
##
@@ -331,6 +351,15 @@ public synchronized Throwable error()
C0urante commented on code in PR #12478:
URL: https://github.com/apache/kafka/pull/12478#discussion_r956043729
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java:
##
@@ -269,7 +289,7 @@ void backoff(int attempt, long deadline
mdedetrich commented on code in PR #12230:
URL: https://github.com/apache/kafka/pull/12230#discussion_r955962277
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -463,8 +463,7 @@ public static T newParameterizedInstance(String
className, Object... param
mdedetrich commented on code in PR #12230:
URL: https://github.com/apache/kafka/pull/12230#discussion_r955962277
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -463,8 +463,7 @@ public static T newParameterizedInstance(String
className, Object... param
[
https://issues.apache.org/jira/browse/KAFKA-14000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585291#comment-17585291
]
Sagar Rao commented on KAFKA-14000:
---
I think one approach to reduce the above error co
[
https://issues.apache.org/jira/browse/KAFKA-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17582519#comment-17582519
]
Sagar Rao edited comment on KAFKA-14015 at 8/26/22 10:24 AM:
-
cadonna commented on code in PR #12562:
URL: https://github.com/apache/kafka/pull/12562#discussion_r955893841
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdaterTest.java:
##
@@ -1139,8 +1209,6 @@ public void shouldGetTasksFromUpdatingTasks(
cadonna commented on code in PR #12562:
URL: https://github.com/apache/kafka/pull/12562#discussion_r955892807
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -60,6 +60,7 @@ private class StateUpdaterThread extends Thread {
vamossagar12 commented on PR #12561:
URL: https://github.com/apache/kafka/pull/12561#issuecomment-1228315761
@C0urante , @showuon , @yashmayya I have created this PR as per the
discussions on the ticket. Plz review whenever you get the chance. Thanks!
--
This is an automated message from
cadonna commented on PR #12562:
URL: https://github.com/apache/kafka/pull/12562#issuecomment-1228315114
Call for review: @wcarlson5 @lihaosky
--
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
cadonna opened a new pull request, #12562:
URL: https://github.com/apache/kafka/pull/12562
The state updater removes its updating and paused task on shutdown.
The removed tasks are added to the output queue for removed tasks.
### Committer Checklist (excluded from commit message
vamossagar12 opened a new pull request, #12561:
URL: https://github.com/apache/kafka/pull/12561
Currently, the Incremental rebalance protocol does not allow a subsequent
revoking rebalance when a worker joins right after one. This can lead to
imbalance in assignments. See
[KAFKA-12495](htt
divijvaidya commented on code in PR #12559:
URL: https://github.com/apache/kafka/pull/12559#discussion_r955882782
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1561,12 +1566,15 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metrics: Metrics) extend
divijvaidya commented on code in PR #12230:
URL: https://github.com/apache/kafka/pull/12230#discussion_r955866446
##
clients/src/main/java/org/apache/kafka/common/utils/Utils.java:
##
@@ -463,8 +463,7 @@ public static T newParameterizedInstance(String
className, Object... para
showuon commented on PR #12559:
URL: https://github.com/apache/kafka/pull/12559#issuecomment-1228282844
@mimaison @rajinisivaram , please take a look. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
showuon commented on code in PR #12559:
URL: https://github.com/apache/kafka/pull/12559#discussion_r955860617
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1546,6 +1546,11 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metrics: Metrics) extend
showuon commented on code in PR #12559:
URL: https://github.com/apache/kafka/pull/12559#discussion_r955857743
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -1561,12 +1566,15 @@ class ConnectionQuotas(config: KafkaConfig, time: Time,
metrics: Metrics) extend
rykovsi opened a new pull request, #12560:
URL: https://github.com/apache/kafka/pull/12560
Changes from RuntimeException to log.info in StandardAuthorizerData.java
In KRaft mode with GSSAPI and ACL when i am adding any new ACL in log file i
am always have a lot of msg like:
ERROR
showuon opened a new pull request, #12559:
URL: https://github.com/apache/kafka/pull/12559
Currently, when client tried to connect to broker, and got throttled or
exceeding connection count (waiting for available connection slot), there will
be no logs output in broker. All the client can s
[
https://issues.apache.org/jira/browse/KAFKA-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585262#comment-17585262
]
Bruno Cadonna commented on KAFKA-14184:
---
[~suresh.ru] Thank you for filing the tic
[
https://issues.apache.org/jira/browse/KAFKA-14182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Svyatoslav updated KAFKA-14182:
---
Description:
In KRaft mode with GSSAPI and ACL when i am adding any new ACL in log file i am
always
[
https://issues.apache.org/jira/browse/KAFKA-14182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Svyatoslav updated KAFKA-14182:
---
Description:
In KRaft mode with GSSAPI and ACL when i am adding any new ACL in log file i am
always
[
https://issues.apache.org/jira/browse/KAFKA-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna updated KAFKA-14184:
--
Component/s: (was: consumer)
> Kafka streams application crashes due to "UnsupportedOperat
[
https://issues.apache.org/jira/browse/KAFKA-14184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Suresh Rukmangathan updated KAFKA-14184:
Description:
Kafka streams application is crashing with following stack trace with
Suresh Rukmangathan created KAFKA-14184:
---
Summary: Kafka streams application crashes due to
"UnsupportedOperationException: this should not happen: timestamp() is not
supported in standby tasks."
Key: KAFKA-14184
cadonna commented on code in PR #12554:
URL: https://github.com/apache/kafka/pull/12554#discussion_r955764822
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateUpdater.java:
##
@@ -183,6 +185,21 @@ public int hashCode() {
*/
Set getActiveTasks
58 matches
Mail list logo
