cadonna commented on code in PR #12835:
URL: https://github.com/apache/kafka/pull/12835#discussion_r1018813558
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java:
##
@@ -191,43 +191,49 @@ void commitOffsetsOrTransaction(final Map allOffsets =
cadonna commented on code in PR #12835:
URL: https://github.com/apache/kafka/pull/12835#discussion_r1018815885
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskExecutorTest.java:
##
@@ -35,4 +45,47 @@ public void testPunctuateWithPause() {
taskE
cadonna commented on code in PR #12835:
URL: https://github.com/apache/kafka/pull/12835#discussion_r1018816579
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -4450,6 +4448,10 @@ public void
shouldNotFailForTimeoutExceptionOnCom
cadonna commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1018831974
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -121,21 +121,32 @@ private void runOnce() throws InterruptedExcept
cadonna commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1018848451
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -277,6 +294,9 @@ private void addTask(final Task task) {
lucasbru opened a new pull request, #12841:
URL: https://github.com/apache/kafka/pull/12841
RestoreIntegrationTest used polling to determine if a rebalance happens on
one client, but if the rebalance would happen too quickly, the polling would
not pick it up and the check would time out.
lucasbru commented on PR #12841:
URL: https://github.com/apache/kafka/pull/12841#issuecomment-1310016220
@cadonna Could you have 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 above to go to th
lucasbru commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1018881878
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -250,30 +261,31 @@ private void removeUpdatingAndPausedTasks() {
Youcef Sebiat created KAFKA-14374:
-
Summary: Kafka streams losing messages in State Store during first
launch of app
Key: KAFKA-14374
URL: https://issues.apache.org/jira/browse/KAFKA-14374
Project: Ka
lucasbru commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1018903133
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -121,21 +121,32 @@ private void runOnce() throws InterruptedExcep
showuon commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1018907375
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java:
##
@@ -1229,4 +1247,23 @@ private boolean in(Set pairs) {
showuon commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1018908171
##
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java:
##
@@ -78,6 +80,26 @@ public void testDecodeGeneration() {
asser
showuon commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1018909824
##
clients/src/test/java/org/apache/kafka/clients/consumer/CooperativeStickyAssignorTest.java:
##
@@ -78,6 +80,26 @@ public void testDecodeGeneration() {
asser
showuon commented on PR #12748:
URL: https://github.com/apache/kafka/pull/12748#issuecomment-1310065769
@dajac , PR updated. Please take a look when available. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
showuon commented on code in PR #12748:
URL: https://github.com/apache/kafka/pull/12748#discussion_r1018917087
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java:
##
@@ -55,12 +60,22 @@ public abstract class AbstractStickyAssigno
cadonna commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1018928862
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -121,21 +121,32 @@ private void runOnce() throws InterruptedExcept
pratimsc commented on PR #12840:
URL: https://github.com/apache/kafka/pull/12840#issuecomment-1310098026
> Should we also bump the `jackson-databind` to 2.13.4.2 for
[CVE-2022-42003](https://github.com/advisories/GHSA-jjjh-jjxp-wpff)?
>
> ref:
[spring-projects/spring-boot#32583](http
lucasbru commented on code in PR #12795:
URL: https://github.com/apache/kafka/pull/12795#discussion_r1018951885
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -250,30 +261,31 @@ private void removeUpdatingAndPausedTasks() {
lucasbru commented on PR #12795:
URL: https://github.com/apache/kafka/pull/12795#issuecomment-1310105681
I noticed we then also shouldn't initialize the task during recycling (to
not get races between state updater and main thread). This was flagged during
smoke testing
--
This is an aut
cadonna commented on PR #12795:
URL: https://github.com/apache/kafka/pull/12795#issuecomment-1310108263
Good catch!
--
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 u
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhangheng Huang reassigned KAFKA-7739:
--
Assignee: Zhangheng Huang (was: Satish Duggana)
> Kafka Tiered Storage
>
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhangheng Huang reassigned KAFKA-7739:
--
Assignee: (was: Zhangheng Huang)
> Kafka Tiered Storage
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-7739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhangheng Huang reassigned KAFKA-7739:
--
Assignee: Satish Duggana
> Kafka Tiered Storage
>
>
>
clolov commented on code in PR #12809:
URL: https://github.com/apache/kafka/pull/12809#discussion_r1019053647
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java:
##
@@ -610,15 +617,21 @@ public Access
cadonna commented on PR #12841:
URL: https://github.com/apache/kafka/pull/12841#issuecomment-1310259756
Build failure is unrelated:
```
Build / JDK 11 and Scala 2.13 /
org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable()
```
--
This is an automat
cadonna merged PR #12841:
URL: https://github.com/apache/kafka/pull/12841
--
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.
mimaison commented on PR #12577:
URL: https://github.com/apache/kafka/pull/12577#issuecomment-1310339077
@OmniaGM I see you pushed updates a few times in the past few days. There's
nothing wrong with that. Just in case you're pushing to rerun the tests, you
can run the MirrorMaker tests loc
OmniaGM commented on PR #12577:
URL: https://github.com/apache/kafka/pull/12577#issuecomment-1310407613
> @OmniaGM I see you pushed updates a few times in the past few days.
There's nothing wrong with that. Just in case you're pushing to rerun the
tests, you can run the MirrorMaker test
cadonna commented on PR #12809:
URL: https://github.com/apache/kafka/pull/12809#issuecomment-1310477888
@clolov, could you please rebase to recent trunk since on trunk there is a
fix for the flaky `RestoreIntegrationTest` which failed quite often in the
builds?
--
This is an automated me
Proven Provenzano created KAFKA-14375:
-
Summary: Remove use of "authorizer-properties" n
EndToEndAuthorizationTest.scala
Key: KAFKA-14375
URL: https://issues.apache.org/jira/browse/KAFKA-14375
Pro
[
https://issues.apache.org/jira/browse/KAFKA-14375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano updated KAFKA-14375:
--
Summary: Remove use of "authorizer-properties" in
EndToEndAuthorizationTest.scala (wa
[
https://issues.apache.org/jira/browse/KAFKA-14375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano updated KAFKA-14375:
--
Description:
The use of {{authorizer-properties}} in AclCommand is deprecated and
End
[
https://issues.apache.org/jira/browse/KAFKA-14375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar reassigned KAFKA-14375:
-
Assignee: Proven Provenzano
> Remove use of "authorizer-properties" in EndToEndAuthorizationTes
OmniaGM commented on PR #12577:
URL: https://github.com/apache/kafka/pull/12577#issuecomment-1310558971
@mimaison Mirror tests are now okay, the pipeline is failing because of
`org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated`
which isn't related
mimaison commented on PR #12577:
URL: https://github.com/apache/kafka/pull/12577#issuecomment-1310586112
Thanks! I'm off tomorrow but I'll take a look early next week.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
lucasbru commented on PR #12795:
URL: https://github.com/apache/kafka/pull/12795#issuecomment-1310605841
The failed tests are unrelated.
```
Build / JDK 11 and Scala 2.13 / testSecondaryRefreshAfterElapsedDelay() –
org.apache.kafka.common.security.oauthbearer.internals.secured.Ref
nicktelford opened a new pull request, #12842:
URL: https://github.com/apache/kafka/pull/12842
While restoring a batch of records, `RocksDBStore` was iterating the
`ConsumerRecord`s, building a list of `KeyValue`s, and then iterating _that_
list of `KeyValue`s to add them to the RocksDB bat
nicktelford commented on PR #12842:
URL: https://github.com/apache/kafka/pull/12842#issuecomment-1310644429
I wasn't sure if this warranted a JIRA ticket, since it's very small. I've
not included any tests because there should not be any behavioural changes
here, and I expect the existing t
Roman Schmitz created KAFKA-14376:
-
Summary: Add ConfigProvider to make use of environment variables
Key: KAFKA-14376
URL: https://issues.apache.org/jira/browse/KAFKA-14376
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-14376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Schmitz updated KAFKA-14376:
--
Description:
So far it is not possible to inject additional configurations stored in
environm
Travis Bischel created KAFKA-14377:
--
Summary: Expose Broker's Name and Version to Clients
Key: KAFKA-14377
URL: https://issues.apache.org/jira/browse/KAFKA-14377
Project: Kafka
Issue Type: I
hachikuji commented on code in PR #12837:
URL: https://github.com/apache/kafka/pull/12837#discussion_r1019455482
##
core/src/main/scala/kafka/server/JointServer.scala:
##
@@ -0,0 +1,237 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributo
[
https://issues.apache.org/jira/browse/KAFKA-14373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Scanteianu updated KAFKA-14373:
--
Description:
creating a producer/consumer involves looking up the consts for kafka
co
Jeff Kim created KAFKA-14378:
Summary: consumer should refresh preferred read replica on update
metadata
Key: KAFKA-14378
URL: https://issues.apache.org/jira/browse/KAFKA-14378
Project: Kafka
Is
Jeff Kim created KAFKA-14379:
Summary: consumer should refresh preferred read replica on update
metadata
Key: KAFKA-14379
URL: https://issues.apache.org/jira/browse/KAFKA-14379
Project: Kafka
Is
Jeff Kim created KAFKA-14380:
Summary: consumer should refresh preferred read replica on
metadata update
Key: KAFKA-14380
URL: https://issues.apache.org/jira/browse/KAFKA-14380
Project: Kafka
Is
Lucas Wang created KAFKA-14381:
--
Summary: Support listing all partitions being reassigned in a
cluster
Key: KAFKA-14381
URL: https://issues.apache.org/jira/browse/KAFKA-14381
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-14381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-14381:
--
Assignee: Lucas Wang
> Support listing all partitions being reassigned in a cluster
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632001#comment-17632001
]
Viktor Utkin commented on KAFKA-9914:
-
This is not a bug, this is misconfiguration:
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12935:
---
Fix Version/s: (was: 3.1.0)
> Flaky Test
> RestoreIntegrationTest.shoul
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-12935:
---
Attachment:
RestoreIntegrationTest#shouldRecycleStateFromStandbyTaskPromoted
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-12935:
--
Assignee: (was: Walker Carlson)
> Flaky Test
> RestoreIntegratio
[
https://issues.apache.org/jira/browse/KAFKA-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632021#comment-17632021
]
A. Sophie Blee-Goldman commented on KAFKA-12935:
Reopening this since it
[
https://issues.apache.org/jira/browse/KAFKA-14378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deng Ziming resolved KAFKA-14378.
-
Resolution: Duplicate
duplicated with KAFKA-14379
> consumer should refresh preferred read repl
[
https://issues.apache.org/jira/browse/KAFKA-14380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deng Ziming resolved KAFKA-14380.
-
Resolution: Duplicate
duplicated with KAFKA-14379
> consumer should refresh preferred read repl
[
https://issues.apache.org/jira/browse/KAFKA-14379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632031#comment-17632031
]
Deng Ziming commented on KAFKA-14379:
-
Hello [~jeffkbkim] , you created another dupl
showuon commented on code in PR #12840:
URL: https://github.com/apache/kafka/pull/12840#discussion_r1019805336
##
LICENSE-binary:
##
@@ -208,18 +208,18 @@ License Version 2.0:
audience-annotations-0.5.0
commons-cli-1.4
commons-lang3-3.12.0
-jackson-annotations-2.13.3
-jackson
A. Sophie Blee-Goldman created KAFKA-14382:
--
Summary: StreamThreads can miss rebalance events when processing
records during a rebalance
Key: KAFKA-14382
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-14382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman updated KAFKA-14382:
---
Description:
One of the main improvements introduced by the cooperative prot
[
https://issues.apache.org/jira/browse/KAFKA-14362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632082#comment-17632082
]
A. Sophie Blee-Goldman commented on KAFKA-14362:
{quote}I would have tho
ableegoldman commented on code in PR #12836:
URL: https://github.com/apache/kafka/pull/12836#discussion_r1019854586
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java:
##
@@ -219,26 +219,20 @@ public void send(final String topic,
[
https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17632093#comment-17632093
]
A. Sophie Blee-Goldman commented on KAFKA-14260:
Seems like we should ju
[
https://issues.apache.org/jira/browse/KAFKA-14260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
A. Sophie Blee-Goldman reassigned KAFKA-14260:
--
Assignee: A. Sophie Blee-Goldman
> InMemoryKeyValueStore iterator sti
showuon commented on code in PR #12753:
URL: https://github.com/apache/kafka/pull/12753#discussion_r1019949776
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -694,6 +694,76 @@ class PlaintextConsumerTest extends BaseConsumerTest {
assertEqua
showuon commented on code in PR #12753:
URL: https://github.com/apache/kafka/pull/12753#discussion_r1019962773
##
core/src/test/scala/integration/kafka/api/PlaintextConsumerTest.scala:
##
@@ -694,6 +694,76 @@ class PlaintextConsumerTest extends BaseConsumerTest {
assertEqua
65 matches
Mail list logo
