[
https://issues.apache.org/jira/browse/KAFKA-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17015.
Resolution: Won't Fix
> ContextualRecord#hashCode()、ProcessorRecordContext#hashCode()
[
https://issues.apache.org/jira/browse/KAFKA-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reopened KAFKA-17015:
> ContextualRecord#hashCode()、ProcessorRecordContext#hashCode() Should not be
> deprecated
[
https://issues.apache.org/jira/browse/KAFKA-17015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dujian0068 resolved KAFKA-17015.
Resolution: Fixed
> ContextualRecord#hashCode()、ProcessorRecordContext#hashCode() Should not be
[
https://issues.apache.org/jira/browse/KAFKA-17025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859799#comment-17859799
]
Hongshun Wang commented on KAFKA-17025:
---
[~gharris1727] Yes, I'd like to do it!
> KafkaThread and
[
https://issues.apache.org/jira/browse/KAFKA-16928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859796#comment-17859796
]
黃竣陽 commented on KAFKA-16928:
-
I'm interesting in this issue, Could you assign to me, thanks
> Test all of
[
https://issues.apache.org/jira/browse/KAFKA-16379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-16379:
-
Summary: Coordinator flush time and event purgatory time metrics (was: add
metric to measure time
[
https://issues.apache.org/jira/browse/KAFKA-17025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859793#comment-17859793
]
Greg Harris commented on KAFKA-17025:
-
I don't think that it is appropriate for the Kafka Producer
José Armando García Sancio created KAFKA-17033:
--
Summary: Consider replacing the directory id Optional with
just Uuid
Key: KAFKA-17033
URL: https://issues.apache.org/jira/browse/KAFKA-17033
[
https://issues.apache.org/jira/browse/KAFKA-16965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-16965:
Component/s: clients
> Add a "root cause" exception as a nested exception to
[
https://issues.apache.org/jira/browse/KAFKA-16965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-16965.
-
Fix Version/s: 3.9.0
Resolution: Fixed
> Add a "root cause" exception as a
[
https://issues.apache.org/jira/browse/KAFKA-16991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859780#comment-17859780
]
Matthias J. Sax commented on KAFKA-16991:
-
Failed again:
[
https://issues.apache.org/jira/browse/KAFKA-17001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859766#comment-17859766
]
Greg Harris commented on KAFKA-17001:
-
[~chia7712] That sounds reasonable. The Supplier.get
[
https://issues.apache.org/jira/browse/KAFKA-17001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859764#comment-17859764
]
Chia-Ping Tsai commented on KAFKA-17001:
{quote}
In situations with "poll-based"
Chia-Ping Tsai created KAFKA-17032:
--
Summary: NioEchoServer should generate meaningful id instead of
incremential number
Key: KAFKA-17032
URL: https://issues.apache.org/jira/browse/KAFKA-17032
[
https://issues.apache.org/jira/browse/KAFKA-17001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859753#comment-17859753
]
Greg Harris commented on KAFKA-17001:
-
IMHO mutable config classes are undesirable, both for
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Josep Prat updated KAFKA-16990:
---
Priority: Major (was: Blocker)
> Unrecognised flag passed to kafka-storage.sh in system test
>
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859746#comment-17859746
]
Josep Prat commented on KAFKA-16990:
Then I'll change the priority to "major" as it's not a blocker
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan reopened KAFKA-16990:
> Unrecognised flag passed to kafka-storage.sh in system test
>
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859743#comment-17859743
]
Justine Olshan commented on KAFKA-16990:
Sorry I will actually reopen until trunk is merged.
>
[
https://issues.apache.org/jira/browse/KAFKA-17031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Christo Lolov updated KAFKA-17031:
--
Description:
*Summary*
We introduce 3 new configurations as part of this KIP. Up to now they
Christo Lolov created KAFKA-17031:
-
Summary: Make configurations public
Key: KAFKA-17031
URL: https://issues.apache.org/jira/browse/KAFKA-17031
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-16853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859742#comment-17859742
]
Christo Lolov commented on KAFKA-16853:
---
Could I also be looped into the review please?
> Split
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859733#comment-17859733
]
Justine Olshan commented on KAFKA-16990:
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859730#comment-17859730
]
Josep Prat commented on KAFKA-16990:
Which was the PR fixing this?
> Unrecognised flag passed to
[
https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16142:
--
Summary: Update metrics documentation for errors (was: Update metrics
documentation for errors and
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-16143:
-
Assignee: Brenden DeLuna (was: Philip Nee)
> New JMX metrics for AsyncKafkaConsumer
>
[
https://issues.apache.org/jira/browse/KAFKA-16142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16142:
--
Description: We need to identify the “errors” that exist in the current JMX
documentation and resolve
[
https://issues.apache.org/jira/browse/KAFKA-16143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-16143:
--
Summary: New JMX metrics for AsyncKafkaConsumer (was: New metrics for
KIP-848 protocol)
> New JMX
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-16990.
Resolution: Fixed
> Unrecognised flag passed to kafka-storage.sh in system test
>
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859727#comment-17859727
]
Justine Olshan edited comment on KAFKA-16990 at 6/24/24 4:08 PM:
-
This
[
https://issues.apache.org/jira/browse/KAFKA-16990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859727#comment-17859727
]
Justine Olshan commented on KAFKA-16990:
This was a blocker, but I merged the fix. (Believe it
[
https://issues.apache.org/jira/browse/KAFKA-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859725#comment-17859725
]
Ayoub Omari commented on KAFKA-14460:
-
[~ableegoldman] Is this ticket only about KeyValueStore ? I
[
https://issues.apache.org/jira/browse/KAFKA-17013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-17013.
Fix Version/s: 3.9.0
Resolution: Fixed
> RequestManager#ConnectionState#toString()
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859717#comment-17859717
]
Chia-Ping Tsai commented on KAFKA-17027:
[~yangpoan] thanks for taking over this jira!
>
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai reassigned KAFKA-17027:
--
Assignee: PoAn Yang
> Inconsistent casing in Selector metrics tags
>
José Armando García Sancio created KAFKA-17030:
--
Summary: Voters should not assume that the leader will send them
BeginQuorumEpoch requests
Key: KAFKA-17030
URL:
[
https://issues.apache.org/jira/browse/KAFKA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859713#comment-17859713
]
Matthias J. Sax commented on KAFKA-16334:
-
Thanks for picking this up. Note, that this ticket
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859714#comment-17859714
]
PoAn Yang commented on KAFKA-17027:
---
Hi [~chiacyu], I saw you deleted the comment. If you're not
[
https://issues.apache.org/jira/browse/KAFKA-16327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859711#comment-17859711
]
Matthias J. Sax commented on KAFKA-16327:
-
[~ksolves.kafka] Thanks for picking this up. The next
Mark McDonald created KAFKA-17029:
-
Summary: SetSchemaMetadata smt throws DataException when avro
schema is primitive type
Key: KAFKA-17029
URL: https://issues.apache.org/jira/browse/KAFKA-17029
philipnee commented on code in PR #16312:
URL: https://github.com/apache/kafka/pull/16312#discussion_r1651126643
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##
@@ -1161,8 +1155,9 @@ public void
Andrew Schofield created KAFKA-17028:
Summary: FindCoordinator v6 initial implementation
Key: KAFKA-17028
URL: https://issues.apache.org/jira/browse/KAFKA-17028
Project: Kafka
Issue
philipnee commented on code in PR #16312:
URL: https://github.com/apache/kafka/pull/16312#discussion_r1651126643
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/MembershipManagerImplTest.java:
##
@@ -1161,8 +1155,9 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-17004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit resolved KAFKA-17004.
---
Fix Version/s: 4.0.0
3.9.0
Resolution: Fixed
> MINOR: Remove
jsancio commented on code in PR #16399:
URL: https://github.com/apache/kafka/pull/16399#discussion_r1651117067
##
raft/src/test/java/org/apache/kafka/raft/RaftClientTestContext.java:
##
@@ -628,7 +629,7 @@ void deliverResponse(int correlationId, Node source,
ApiMessage
[
https://issues.apache.org/jira/browse/KAFKA-17001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kuan Po Tseng updated KAFKA-17001:
--
Summary: Consider using another class to replace `AbstractConfig` to be
class which always
omkreddy merged PR #16436:
URL: https://github.com/apache/kafka/pull/16436
--
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:
jsancio commented on code in PR #16399:
URL: https://github.com/apache/kafka/pull/16399#discussion_r1651079179
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -2096,6 +2096,26 @@ private long maybeAppendBatches(
return timeUntilDrain;
}
+
jsancio commented on code in PR #16399:
URL: https://github.com/apache/kafka/pull/16399#discussion_r1651084728
##
raft/src/main/java/org/apache/kafka/raft/LeaderState.java:
##
@@ -220,7 +234,14 @@ public Uuid localDirectoryId() {
return localDirectoryId;
}
-
[
https://issues.apache.org/jira/browse/KAFKA-14348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859698#comment-17859698
]
Ksolves edited comment on KAFKA-14348 at 6/24/24 2:13 PM:
--
[~cmccabe] It's an
[
https://issues.apache.org/jira/browse/KAFKA-14348?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859698#comment-17859698
]
Ksolves commented on KAFKA-14348:
-
[~cmccabe] It's an old ticket but would like to confirm if the change
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859695#comment-17859695
]
Mickael Maison commented on KAFKA-17027:
[~chia7712] Since we'll have a 3.9 release, yeah we
[ https://issues.apache.org/jira/browse/KAFKA-17027 ]
Chia Chuan Yu deleted comment on KAFKA-17027:
---
was (Author: JIRAUSER304417):
Hi, [~mimaison]
Can I have this one? I'm interested in this task. Thanks!
> Inconsistent casing in Selector
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859693#comment-17859693
]
Mickael Maison commented on KAFKA-17027:
[~chiacyu] If a ticket is not assigned to anybody, feel
[
https://issues.apache.org/jira/browse/KAFKA-13867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859692#comment-17859692
]
Ksolves commented on KAFKA-13867:
-
[~cmccabe] There are no variable named "version" defined in the
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859690#comment-17859690
]
Chia Chuan Yu commented on KAFKA-17027:
---
Hi, [~mimaison]
Can I have this one? I'm interested in
[
https://issues.apache.org/jira/browse/KAFKA-17027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859689#comment-17859689
]
Chia-Ping Tsai commented on KAFKA-17027:
Should we deprecate the non lower camel metrics? If so,
Mickael Maison created KAFKA-17027:
--
Summary: Inconsistent casing in Selector metrics tags
Key: KAFKA-17027
URL: https://issues.apache.org/jira/browse/KAFKA-17027
Project: Kafka
Issue Type:
adixitconfluent commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650928682
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
jsancio commented on code in PR #16325:
URL: https://github.com/apache/kafka/pull/16325#discussion_r1651072253
##
core/src/main/scala/kafka/tools/StorageTool.scala:
##
@@ -102,6 +109,11 @@ object StorageTool extends Logging {
setClusterId(clusterId).
[
https://issues.apache.org/jira/browse/KAFKA-16967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-16967.
Fix Version/s: 3.9.0
Resolution: Fixed
> NioEchoServer fails to register
chia7712 merged PR #16384:
URL: https://github.com/apache/kafka/pull/16384
--
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:
chia7712 commented on code in PR #16019:
URL: https://github.com/apache/kafka/pull/16019#discussion_r1651048314
##
tools/src/main/java/org/apache/kafka/tools/consumer/TransactionLogMessageFormatter.java:
##
@@ -0,0 +1,119 @@
+/*
+ * Licensed to the Apache Software Foundation
muralibasani commented on PR #16257:
URL: https://github.com/apache/kafka/pull/16257#issuecomment-2186577649
> Heya @muralibasani, could you just fix
>
> ```
> [2024-06-21T10:19:19.373Z]
sebastienviale commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1651019264
##
streams/src/test/java/org/apache/kafka/streams/integration/ProcessingExceptionHandlerIntegrationTest.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the
adixitconfluent commented on code in PR #16430:
URL: https://github.com/apache/kafka/pull/16430#discussion_r1651002843
##
checkstyle/suppressions.xml:
##
@@ -39,6 +39,7 @@
+
Review Comment:
actually I had refactored and reduced the complexity in one of my
clolov commented on PR #16257:
URL: https://github.com/apache/kafka/pull/16257#issuecomment-2186519073
Heya @muralibasani, could you just fix
```
[2024-06-21T10:19:19.373Z]
clolov commented on code in PR #16257:
URL: https://github.com/apache/kafka/pull/16257#discussion_r1650984849
##
metadata/src/main/resources/common/metadata/TopicRecord.json:
##
@@ -17,12 +17,16 @@
"apiKey": 2,
"type": "metadata",
"name": "TopicRecord",
-
frankvicky commented on PR #16384:
URL: https://github.com/apache/kafka/pull/16384#issuecomment-2186497190
Hi @chia7712,
I have run the failing test on both the trunk and the 16967 branch on my
local machine, but I couldn't reproduce the failure. I also reviewed the
failing test,
adixitconfluent commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650969451
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
Nancy-ksolves opened a new pull request, #16438:
URL: https://github.com/apache/kafka/pull/16438
Upgrade the document to add remote copy/fetch quotas metrics values.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
adixitconfluent commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650969451
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
adixitconfluent commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650969451
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
chia7712 commented on code in PR #16019:
URL: https://github.com/apache/kafka/pull/16019#discussion_r1650961363
##
tools/src/main/java/org/apache/kafka/tools/consumer/TransactionLogMessageFormatter.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation
chia7712 commented on PR #16420:
URL: https://github.com/apache/kafka/pull/16420#issuecomment-2186476992
BTW, there is a description in KIP-584
> Each broker’s supported dictionary of {feature → version range} will be
defined in the broker code. For each supported feature, the
sebastienviale commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1650933888
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java:
##
@@ -63,6 +95,36 @@ public void
sebastienviale commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1650931604
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java:
##
@@ -99,30 +81,57 @@ public void
adixitconfluent commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650931188
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
adixitconfluent commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650928682
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
[
https://issues.apache.org/jira/browse/KAFKA-15138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859653#comment-17859653
]
Romain Quinio commented on KAFKA-15138:
---
Any news on this ? Lz4-java is no longer maintained
[
https://issues.apache.org/jira/browse/KAFKA-15138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859653#comment-17859653
]
Romain Quinio edited comment on KAFKA-15138 at 6/24/24 12:07 PM:
-
Any
apoorvmittal10 commented on code in PR #16430:
URL: https://github.com/apache/kafka/pull/16430#discussion_r1650900179
##
checkstyle/suppressions.xml:
##
@@ -39,6 +39,7 @@
+
Review Comment:
Can we reduce the cyclomatic complexity? I have refactored acquire
apoorvmittal10 commented on code in PR #16431:
URL: https://github.com/apache/kafka/pull/16431#discussion_r1650896425
##
core/src/test/java/kafka/server/share/SharePartitionManagerTest.java:
##
@@ -1221,6 +1224,36 @@ public void testReplicaManagerFetchShouldProceed() {
m1a2st commented on code in PR #16019:
URL: https://github.com/apache/kafka/pull/16019#discussion_r1650898140
##
tools/src/main/java/org/apache/kafka/tools/consumer/TransactionLogMessageFormatter.java:
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-16749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-16749.
---
Resolution: Done
> Implement share fetch messages
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-16999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-16999.
---
Resolution: Done
> Integrate persister read API in Partition leader initilization
>
[
https://issues.apache.org/jira/browse/KAFKA-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-16748.
---
Resolution: Fixed
> Implement share response handling in SharePartitionManager
>
[
https://issues.apache.org/jira/browse/KAFKA-17026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Abhinav Dixit updated KAFKA-17026:
--
Summary: Implement updateCacheAndOffsets functionality on LSO movement
(was: Implement
apoorvmittal10 commented on code in PR #16422:
URL: https://github.com/apache/kafka/pull/16422#discussion_r1650869359
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1513,7 +1513,7 @@ private Thread shutdownHelper(final boolean error, final
long
cadonna commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1650830032
##
streams/src/test/java/org/apache/kafka/streams/integration/ProcessingExceptionHandlerIntegrationTest.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the Apache
cadonna commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1650830032
##
streams/src/test/java/org/apache/kafka/streams/integration/ProcessingExceptionHandlerIntegrationTest.java:
##
@@ -0,0 +1,400 @@
+/*
+ * Licensed to the Apache
ashoke-cube commented on PR #16095:
URL: https://github.com/apache/kafka/pull/16095#issuecomment-2186292726
> > Hi @ashoke-cube could you fix the build? Thanks!
>
> Hey @gharris1727 I looked into the build failure. It is a bit weird. It is
failing because it is not able to find the
cadonna commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1650786044
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorNodeTest.java:
##
@@ -99,30 +81,57 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859641#comment-17859641
]
Caio César commented on KAFKA-16334:
I would like to work on this task. :)
> Remove Deprecated
[
https://issues.apache.org/jira/browse/KAFKA-16334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Caio César reassigned KAFKA-16334:
--
Assignee: Caio César
> Remove Deprecated command line option from reset tool
>
cadonna commented on code in PR #16093:
URL: https://github.com/apache/kafka/pull/16093#discussion_r1650767327
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StampedRecord.java:
##
@@ -49,6 +51,21 @@ public Headers headers() {
return
chia7712 commented on code in PR #16420:
URL: https://github.com/apache/kafka/pull/16420#discussion_r1650736148
##
clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java:
##
@@ -258,11 +259,22 @@ private static ApiVersionsResponseData
Abhinav Dixit created KAFKA-17026:
-
Summary: Implement updateCachedAndOffsets functionality on LSO
movement
Key: KAFKA-17026
URL: https://issues.apache.org/jira/browse/KAFKA-17026
Project: Kafka
aliehsaeedii commented on code in PR #16344:
URL: https://github.com/apache/kafka/pull/16344#discussion_r1650696721
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -1175,19 +1176,26 @@ private ClusterAndWaitTime waitOnMetadata(String topic,
[
https://issues.apache.org/jira/browse/KAFKA-16551?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17859634#comment-17859634
]
PoAn Yang commented on KAFKA-16551:
---
Yes, let me handle it. Thank you.
> add integration test for
1 - 100 of 131 matches
Mail list logo
