[
https://issues.apache.org/jira/browse/KAFKA-17147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18018978#comment-18018978
]
TaiJuWu commented on KAFKA-17147:
-
Hi [~jsancio] , if you are not working on this, may I
[
https://issues.apache.org/jira/browse/KAFKA-19689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker updated KAFKA-19689:
--
Summary: TopologyTestDriver spends most of its time forcing changes to disk
with persi
chia7712 merged PR #17930:
URL: https://github.com/apache/kafka/pull/17930
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Logan Zhu reassigned KAFKA-19692:
-
Assignee: Logan Zhu (was: Chia-Ping Tsai)
> improve the docs of "clusterId" for AddRaftVoterOp
chia7712 merged PR #20446:
URL: https://github.com/apache/kafka/pull/20446
--
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
chia7712 commented on PR #20446:
URL: https://github.com/apache/kafka/pull/20446#issuecomment-3268892847
> If that is the case, on the one hand this is just a refactoring; on the
other hand it's not an area of the code I'm familiar with. Not a huge deal to
change - it seems like other usage
chia7712 commented on code in PR #20491:
URL: https://github.com/apache/kafka/pull/20491#discussion_r2332025981
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumerTest.java:
##
@@ -2029,6 +2030,28 @@ public void
testRecordBackgroundEventQueue
[
https://issues.apache.org/jira/browse/KAFKA-17255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu resolved KAFKA-17255.
-
Resolution: Duplicate
> Migrate ListOffsetsIntegrationTest to ClusterTestExtensions framework
>
[
https://issues.apache.org/jira/browse/KAFKA-19680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker resolved KAFKA-19680.
---
Resolution: Duplicate
> NoSuchElementException (again) in Kafka Streams iterator met
github-actions[bot] commented on PR #20450:
URL: https://github.com/apache/kafka/pull/20450#issuecomment-3268714876
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20454:
URL: https://github.com/apache/kafka/pull/20454#issuecomment-3268714780
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
github-actions[bot] commented on PR #20392:
URL: https://github.com/apache/kafka/pull/20392#issuecomment-3268714988
A label of 'needs-attention' was automatically added to this PR in order to
raise the
attention of the committers. Once this issue has been triaged, the `triage`
label
s
[
https://issues.apache.org/jira/browse/KAFKA-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18191:
Description:
The StreamJoined#as API allows you to set a name for a stream-stream join
op
[
https://issues.apache.org/jira/browse/KAFKA-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18191:
Priority: Minor (was: Major)
> StreamJoined name is not used for processor names
> --
[
https://issues.apache.org/jira/browse/KAFKA-19691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
travis updated KAFKA-19691:
---
Affects Version/s: 4.2.0
> Add metrics corresponding to consumer rebalance listener metrics
> --
travis created KAFKA-19691:
--
Summary: Add metrics corresponding to consumer rebalance listener
metrics
Key: KAFKA-19691
URL: https://issues.apache.org/jira/browse/KAFKA-19691
Project: Kafka
Issue T
[
https://issues.apache.org/jira/browse/KAFKA-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18191:
Description:
The StreamJoined#as API allows you to set a name for a stream-stream join
op
[
https://issues.apache.org/jira/browse/KAFKA-18191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18191:
Labels: needs-kip (was: )
> StreamJoined name is not used for processor names
> -
mjsax commented on PR #20408:
URL: https://github.com/apache/kafka/pull/20408#issuecomment-3268456014
Thanks for the PR @shashankhs11. Merged to `trunk` and cherry-picked to
`4.1` branch.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mjsax merged PR #20408:
URL: https://github.com/apache/kafka/pull/20408
--
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.or
[
https://issues.apache.org/jira/browse/KAFKA-19679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18018911#comment-18018911
]
Matthias J. Sax commented on KAFKA-19679:
-
Oh dear... :(
> NoSuchElementExcepti
[
https://issues.apache.org/jira/browse/KAFKA-19690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19690:
Component/s: core
streams
> Unexpected Fatal error InvalidTxnStateExcepti
[
https://issues.apache.org/jira/browse/KAFKA-19690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19690:
Affects Version/s: 4.1.0
> Unexpected Fatal error InvalidTxnStateException on Kafka Stream
Ritika Reddy created KAFKA-19690:
Summary: Unexpected Fatal error InvalidTxnStateException on Kafka
Streams (KIP-890)
Key: KAFKA-19690
URL: https://issues.apache.org/jira/browse/KAFKA-19690
Project: K
[
https://issues.apache.org/jira/browse/KAFKA-19689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker updated KAFKA-19689:
--
Description:
We are using TopologyTestDriverÂ
It looks like the test driver is syncin
Yunyung commented on code in PR #20479:
URL: https://github.com/apache/kafka/pull/20479#discussion_r2331457224
##
tools/src/main/java/org/apache/kafka/tools/consumer/ConsoleShareConsumerOptions.java:
##
@@ -58,11 +58,21 @@ public ConsoleShareConsumerOptions(String[] args) throws
[
https://issues.apache.org/jira/browse/KAFKA-19687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
TaiJuWu reassigned KAFKA-19687:
---
Assignee: TaiJuWu
> MetaData log error message for SNAPSHOT_HEADER and SNAPSHOT_FOOTER
> --
[
https://issues.apache.org/jira/browse/KAFKA-19689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Schlansker resolved KAFKA-19689.
---
Resolution: Invalid
I apologize, this was actually a correlated change on our end, n
TaiJuWu commented on code in PR #20466:
URL: https://github.com/apache/kafka/pull/20466#discussion_r2330873629
##
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala:
##
@@ -1786,13 +1786,12 @@ class KafkaConfigTest {
// This is OK.
props.put(GroupCoordinato
Steven Schlansker created KAFKA-19689:
-
Summary: TopologyTestDriver spends most of its time forcing
changes to disk
Key: KAFKA-19689
URL: https://issues.apache.org/jira/browse/KAFKA-19689
Project:
[
https://issues.apache.org/jira/browse/KAFKA-19638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-19638:
---
Assignee: Eduwer Camacaro
> NPE in `Processor#init()` accessing state store
> -
mjsax commented on code in PR #20403:
URL: https://github.com/apache/kafka/pull/20403#discussion_r2331376906
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -1104,11 +1104,18 @@ private void initializeTopology() {
// initiali
[
https://issues.apache.org/jira/browse/KAFKA-19668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18018898#comment-18018898
]
ASF GitHub Bot commented on KAFKA-19668:
mjsax merged PR #721:
URL: https://gith
mjsax merged PR #20506:
URL: https://github.com/apache/kafka/pull/20506
--
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.or
mjsax opened a new pull request, #20506:
URL: https://github.com/apache/kafka/pull/20506
Delete this text and replace it with a detailed description of your change.
The
PR title and body will become the squashed commit message.
If you would like to tag individuals, add some commen
[
https://issues.apache.org/jira/browse/KAFKA-19668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18018893#comment-18018893
]
ASF GitHub Bot commented on KAFKA-19668:
mjsax commented on code in PR #721:
URL
Matthias J. Sax created KAFKA-19688:
---
Summary: Provide clean upgrade path from transformValues to
processValues
Key: KAFKA-19688
URL: https://issues.apache.org/jira/browse/KAFKA-19688
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-19668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18018892#comment-18018892
]
ASF GitHub Bot commented on KAFKA-19668:
mjsax opened a new pull request, #721:
TaiJuWu opened a new pull request, #20505:
URL: https://github.com/apache/kafka/pull/20505
Ignore SNAPSHOT_HEADER and SNAPSHOT_FOOTER when reading snapshots to avoid
to log such error messages.
--
This is an automated message from the Apache Git Service.
To respond to the message, please
lucasbru commented on PR #20378:
URL: https://github.com/apache/kafka/pull/20378#issuecomment-3264941684
@shashankhs11 can you please close the PRs that we do not want to merge now
or give them a discriptive name and order? There are too many PRs and I don't
know which I should look at
--
see-quick commented on code in PR #20468:
URL: https://github.com/apache/kafka/pull/20468#discussion_r2329636362
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -44,7 +44,7 @@ import org.apache.kafka.common.security.auth.SecurityProtocol
import org.apache.kafka.c
Copilot commented on code in PR #20465:
URL: https://github.com/apache/kafka/pull/20465#discussion_r2329360565
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java:
##
@@ -110,15 +110,12 @@ SmokeTestDriver.Verificati
josefk31 commented on PR #20446:
URL: https://github.com/apache/kafka/pull/20446#issuecomment-3266994013
> It seems the word `maxBatchSize` is still used in code case. Should we
align them in this PR?
@chia7712 do you mean it's still used
[here](https://github.com/apache/kafka/blob/f
lucasbru commented on code in PR #20486:
URL: https://github.com/apache/kafka/pull/20486#discussion_r2330103941
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignor.java:
##
@@ -193,6 +196,9 @@ private void assignActive(final
[
https://issues.apache.org/jira/browse/KAFKA-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ksolves India Limited reassigned KAFKA-19097:
-
Assignee: Ksolves India Limited (was: HongYi Chen)
> Fix order of argu
lucasbru commented on code in PR #20457:
URL: https://github.com/apache/kafka/pull/20457#discussion_r2330119126
##
core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala:
##
@@ -4441,6 +4442,55 @@ class PlaintextAdminIntegrationTest extends
BaseAdminInteg
TaiJuWu commented on code in PR #20466:
URL: https://github.com/apache/kafka/pull/20466#discussion_r2330871537
##
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala:
##
@@ -1786,13 +1786,12 @@ class KafkaConfigTest {
// This is OK.
props.put(GroupCoordinato
TaiJuWu created KAFKA-19687:
---
Summary: MetaData log error message for SNAPSHOT_HEADER and
SNAPSHOT_FOOTER
Key: KAFKA-19687
URL: https://issues.apache.org/jira/browse/KAFKA-19687
Project: Kafka
Iss
kirktrue commented on PR #20324:
URL: https://github.com/apache/kafka/pull/20324#issuecomment-3267125924
I'm closing this PR as we have decided against going any further with this
approach due to thread safety concerns.
cc @lianetm @AndrewJSchofield
--
This is an automated message
lucliu1108 commented on PR #20496:
URL: https://github.com/apache/kafka/pull/20496#issuecomment-3266940973
Added a waitUtilTrue to wait until all groups are stable before validating
the listGroup contents.
--
This is an automated message from the Apache Git Service.
To respond to the mess
lucasbru merged PR #20465:
URL: https://github.com/apache/kafka/pull/20465
--
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
eduwercamacaro commented on code in PR #20403:
URL: https://github.com/apache/kafka/pull/20403#discussion_r2330605579
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java:
##
@@ -1104,11 +1104,18 @@ private void initializeTopology() {
//
Mickael Maison created KAFKA-19686:
--
Summary: Trigger Docker image builds in release script
Key: KAFKA-19686
URL: https://issues.apache.org/jira/browse/KAFKA-19686
Project: Kafka
Issue Type:
mimaison commented on code in PR #20478:
URL: https://github.com/apache/kafka/pull/20478#discussion_r2330525031
##
release/release.py:
##
@@ -200,12 +200,113 @@ def command_release_announcement_email():
dev_branch = '.'.join(release_version_parts[:2])
docs_release_version = do
lucasbru merged PR #20483:
URL: https://github.com/apache/kafka/pull/20483
--
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
chia7712 commented on code in PR #20492:
URL: https://github.com/apache/kafka/pull/20492#discussion_r2330399941
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -1658,7 +1658,7 @@ class Partition(val topicPartition: TopicPartition,
def deleteRecordsOnLeader(offset:
m1a2st opened a new pull request, #20504:
URL: https://github.com/apache/kafka/pull/20504
When using the find command, it currently lists all directories and files.
However, if it cannot find a child node, it throws an exception and prevents
the subsequent directories from being printed. I
bbejeck commented on code in PR #20486:
URL: https://github.com/apache/kafka/pull/20486#discussion_r2330289507
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacyStickyTaskAssignorTest.java:
##
@@ -1263,6 +1263,119 @@ public void
shouldRemain
bbejeck commented on code in PR #20486:
URL: https://github.com/apache/kafka/pull/20486#discussion_r2330287941
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignorTest.java:
##
@@ -1091,6 +1091,148 @@ public void
shouldHandle
lucasbru commented on code in PR #20457:
URL: https://github.com/apache/kafka/pull/20457#discussion_r2330180515
##
core/src/test/scala/integration/kafka/api/IntegrationTestHarness.scala:
##
@@ -239,7 +239,8 @@ abstract class IntegrationTestHarness extends
KafkaServerTestHarness
lucasbru commented on code in PR #20457:
URL: https://github.com/apache/kafka/pull/20457#discussion_r2330173867
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -16216,6 +16216,98 @@ barTopicName, computeTopicHash(barTopi
lucasbru commented on code in PR #20457:
URL: https://github.com/apache/kafka/pull/20457#discussion_r2330172947
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -6005,7 +6010,13 @@ public void replay(
if (value ==
lucasbru commented on code in PR #20486:
URL: https://github.com/apache/kafka/pull/20486#discussion_r2330109103
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/LegacyStickyTaskAssignorTest.java:
##
@@ -1263,6 +1263,119 @@ public void
shouldRemai
lucasbru commented on code in PR #20486:
URL: https://github.com/apache/kafka/pull/20486#discussion_r2330105629
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignor.java:
##
@@ -296,9 +302,13 @@ private boolean hasUnfulfilledQ
[
https://issues.apache.org/jira/browse/KAFKA-19332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal reassigned KAFKA-19332:
-
Assignee: Sanskar Jhajharia (was: Apoorv Mittal)
> Fix flaky test :
> testAlterReadCo
[
https://issues.apache.org/jira/browse/KAFKA-19630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-19630.
---
Fix Version/s: 4.2.0
Resolution: Fixed
> LSO movement archives only the first availab
lucasbru commented on PR #20382:
URL: https://github.com/apache/kafka/pull/20382#issuecomment-3264942101
Close?
--
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
see-quick commented on code in PR #20468:
URL: https://github.com/apache/kafka/pull/20468#discussion_r2329654875
##
metadata/src/main/java/org/apache/kafka/metadata/publisher/ScramPublisher.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
see-quick commented on code in PR #20468:
URL: https://github.com/apache/kafka/pull/20468#discussion_r2329645606
##
metadata/src/main/java/org/apache/kafka/metadata/publisher/ScramPublisher.java:
##
@@ -0,0 +1,70 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under
see-quick commented on code in PR #20468:
URL: https://github.com/apache/kafka/pull/20468#discussion_r2329659275
##
server-common/src/main/java/org/apache/kafka/server/common/CredentialProvider.java:
##
Review Comment:
Yeah, I think that's a good idea.
--
This is an aut
oertl commented on PR #20359:
URL: https://github.com/apache/kafka/pull/20359#issuecomment-3265152054
@mimaison, is there anything I can do to bring this PR forward?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/KAFKA-19097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18018759#comment-18018759
]
Ksolves India Limited commented on KAFKA-19097:
---
Hi [~mjsax] / [~lorcanj],
joshua2519 commented on code in PR #20083:
URL: https://github.com/apache/kafka/pull/20083#discussion_r2329424425
##
storage/src/main/java/org/apache/kafka/storage/internals/log/OngoingReassignmentState.java:
##
@@ -0,0 +1,42 @@
+/*
+ * Licensed to the Apache Software Foundation
Copilot commented on code in PR #20498:
URL: https://github.com/apache/kafka/pull/20498#discussion_r2329360643
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/RestoreIntegrationTest.java:
##
@@ -161,8 +159,8 @@ public void createTopics(final TestI
lucasbru merged PR #20463:
URL: https://github.com/apache/kafka/pull/20463
--
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
lucasbru commented on PR #20463:
URL: https://github.com/apache/kafka/pull/20463#issuecomment-3264933777
Hey @shashankhs11 . Could you name your PRs:
KAFKA-19666: {descriptive naming} [k/N] -- so that we understand which is
which?
This one, for example, I'll name
KAFKA-1
76 matches
Mail list logo
