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
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
[
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
[
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
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-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
[
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
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
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
[
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
[
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-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-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-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: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 updated KAFKA-12935:
---
Fix Version/s: (was: 3.1.0)
> Flaky Test
> RestoreIntegrationTest.shoul
[
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-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
> ---
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
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
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-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
[
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
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
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
[
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
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
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
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
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
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
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
[
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
[
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
]
Proven Provenzano updated KAFKA-14375:
--
Summary: Remove use of "authorizer-properties" in
EndToEndAuthorizationTest.scala (wa
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
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
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
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
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.
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
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
[
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
>
>
>
[
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: Zhangheng Huang (was: Satish Duggana)
> Kafka Tiered Storage
>
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
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
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() {
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
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
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
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_r1018909824
##
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_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_r1018907375
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java:
##
@@ -1229,4 +1247,23 @@ private boolean in(Set pairs) {
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
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_r1018881878
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java:
##
@@ -250,30 +261,31 @@ private void removeUpdatingAndPausedTasks() {
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 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.
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) {
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 #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 #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_r1018813558
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java:
##
@@ -191,43 +191,49 @@ void commitOffsetsOrTransaction(final Map allOffsets =
65 matches
Mail list logo
