[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746794#comment-17746794
]
Manikumar edited comment on KAFKA-15243 at 7/25/23 6:26 AM:
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746794#comment-17746794
]
Manikumar commented on KAFKA-15243:
---
[Sergio
Troiano|https://mail.google.com/jira/sec
Abhijeet Kumar created KAFKA-15245:
--
Summary: Improve Tiered Storage Metrics
Key: KAFKA-15245
URL: https://issues.apache.org/jira/browse/KAFKA-15245
Project: Kafka
Issue Type: Sub-task
vamossagar12 commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1649138031
hmm I still see 93 test failures out of which 90 are from JDK 11 build.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitH
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1273004953
##
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json:
##
@@ -29,7 +29,20 @@
{ "name": "TopicName", "versions": "0+",
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746774#comment-17746774
]
Sagar Rao commented on KAFKA-15005:
---
[~LucentWong], the PR for https://issues.apache.o
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sagar Rao resolved KAFKA-15005.
---
Resolution: Duplicate
> Status of KafkaConnect task not correct
> --
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1273003055
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SubscribedTopicDescriber.java:
##
@@ -0,0 +1,59 @@
+/*
+ * Licensed to the Apache Softw
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272999133
##
checkstyle/suppressions.xml:
##
@@ -321,6 +321,8 @@
+
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272998731
##
checkstyle/import-control.xml:
##
@@ -48,6 +48,7 @@
+
Review Comment:
yep correct we don't need it now that we don't have any classes in it
--
cmccabe closed pull request #14087: Kafka 15183 ii
URL: https://github.com/apache/kafka/pull/14087
--
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-
cmccabe merged PR #14010:
URL: https://github.com/apache/kafka/pull/14010
--
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.
github-actions[bot] commented on PR #12787:
URL: https://github.com/apache/kafka/pull/12787#issuecomment-1649012604
This PR is being marked as stale since it has not had any activity in 90
days. If you would like to keep this PR alive, please ask a committer for
review. If the PR has merge
mumrah commented on code in PR #14028:
URL: https://github.com/apache/kafka/pull/14028#discussion_r1272796566
##
server-common/src/main/java/org/apache/kafka/server/metrics/MetadataTypeMetric.java:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
[
https://issues.apache.org/jira/browse/KAFKA-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746733#comment-17746733
]
shilin Lu commented on KAFKA-15240:
---
[~ijuma] [~junrao] please watch this issue，thank
vamossagar12 commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1648892717
I see 92 tests failed this time. I think I also have access to re-trigger
builds but have never been able to login to Jenkins.
--
This is an automated message from the Apache Git
gharris1727 commented on PR #14064:
URL: https://github.com/apache/kafka/pull/14064#issuecomment-1648823990
#14089 contains the fix for the PluginType inference which this change
requires.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
gharris1727 opened a new pull request, #14089:
URL: https://github.com/apache/kafka/pull/14089
This method is misleading, as it makes the caller assume that a given plugin
class has only one supertype, when it may actually have multiple. Rather than
documenting this limitation, or having th
Greg Harris created KAFKA-15244:
---
Summary: Connect PluginType.from(Class) result is incorrect when
subclassing multiple plugin interfaces
Key: KAFKA-15244
URL: https://issues.apache.org/jira/browse/KAFKA-15244
[
https://issues.apache.org/jira/browse/KAFKA-14969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746711#comment-17746711
]
Ismael Juma commented on KAFKA-14969:
-
This is sort of done already:
https://github
jolshan commented on code in PR #14088:
URL: https://github.com/apache/kafka/pull/14088#discussion_r1272869719
##
core/src/test/scala/unit/kafka/server/AddPartitionsToTxnManagerTest.scala:
##
@@ -201,7 +201,7 @@ class AddPartitionsToTxnManagerTest {
assertEquals(expectedDis
hachikuji commented on code in PR #14088:
URL: https://github.com/apache/kafka/pull/14088#discussion_r1272868243
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -732,8 +732,7 @@ class ReplicaManager(val config: KafkaConfig,
debug("Produce to local log in
CalvinConfluent commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1272855952
##
core/src/main/scala/kafka/cluster/Replica.scala:
##
@@ -98,31 +101,39 @@ class Replica(val brokerId: Int, val topicPartition:
TopicPartition) extends Log
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1272854832
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5205,11 +5245,102 @@ public void
testReplaceStaticMemberI
CalvinConfluent commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1272852459
##
core/src/main/scala/kafka/cluster/Replica.scala:
##
@@ -98,31 +101,39 @@ class Replica(val brokerId: Int, val topicPartition:
TopicPartition) extends Log
CalvinConfluent commented on code in PR #14053:
URL: https://github.com/apache/kafka/pull/14053#discussion_r1272852459
##
core/src/main/scala/kafka/cluster/Replica.scala:
##
@@ -98,31 +101,39 @@ class Replica(val brokerId: Int, val topicPartition:
TopicPartition) extends Log
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1272852347
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadat
jeffkbkim commented on code in PR #14017:
URL: https://github.com/apache/kafka/pull/14017#discussion_r1272851939
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5524,5 +5670,2897 @@ private static Record newGroupMetadat
jolshan opened a new pull request, #14088:
URL: https://github.com/apache/kafka/pull/14088
Invalid record is a newer error. Invalid_Txn_State has been around as long
as transactions and is not retriable. This is the desired behavior.
### Committer Checklist (excluded from commit m
cmccabe opened a new pull request, #14087:
URL: https://github.com/apache/kafka/pull/14087
get test run for https://github.com/apache/kafka/pull/14010
--
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
[
https://issues.apache.org/jira/browse/KAFKA-14920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-14920.
Resolution: Fixed
> Address timeouts and out of order sequences
>
[
https://issues.apache.org/jira/browse/KAFKA-14969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746667#comment-17746667
]
Said BOUDJELDA commented on KAFKA-14969:
Can I take this ticket, and prepare eve
[
https://issues.apache.org/jira/browse/KAFKA-14969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Said BOUDJELDA updated KAFKA-14969:
---
Labels: dependencies (was: )
> Upgrade Mockito to 4.11.0
> -
>
>
cmccabe commented on PR #13643:
URL: https://github.com/apache/kafka/pull/13643#issuecomment-1648709714
Thanks, @jsancio . I updated the PR with the results of our discussion. One
small change I made is that I think `RaftClient#logEndOffset` can just
unconditionally return the log end offse
[
https://issues.apache.org/jira/browse/KAFKA-15235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746659#comment-17746659
]
Eike Thaden commented on KAFKA-15235:
-
@Said: Thank you for the additional explanati
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746655#comment-17746655
]
Lixin Yao commented on KAFKA-15214:
---
Hi [~divijvaidya] , any further suggestion? Is th
philipnee opened a new pull request, #14086:
URL: https://github.com/apache/kafka/pull/14086
*A missing piece from
[KAFKA-14950](https://issues.apache.org/jira/browse/KAFKA-14950). This is to
test assign() and assignment() in the integration test.
### Committer Checklist (excluded fr
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1272791951
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignorTest.java:
##
@@ -145,147 +188,517 @@ public void disableActiveSi
cmccabe commented on code in PR #14028:
URL: https://github.com/apache/kafka/pull/14028#discussion_r1272782778
##
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetrics.java:
##
@@ -117,6 +120,15 @@ public Integer value() {
return (
cmccabe commented on code in PR #14028:
URL: https://github.com/apache/kafka/pull/14028#discussion_r1272782778
##
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetrics.java:
##
@@ -117,6 +120,15 @@ public Integer value() {
return (
cmccabe commented on code in PR #14028:
URL: https://github.com/apache/kafka/pull/14028#discussion_r1272784428
##
server-common/src/main/java/org/apache/kafka/server/metrics/MetadataTypeMetric.java:
##
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
cmccabe commented on code in PR #14028:
URL: https://github.com/apache/kafka/pull/14028#discussion_r1272782778
##
metadata/src/main/java/org/apache/kafka/controller/metrics/ControllerMetadataMetrics.java:
##
@@ -117,6 +120,15 @@ public Integer value() {
return (
mjsax opened a new pull request, #14085:
URL: https://github.com/apache/kafka/pull/14085
Porting fixes from https://github.com/apache/kafka-site/pull/528 back.
This should also be cherry-picked to `3.5` branch.
--
This is an automated message from the Apache Git Service.
To respond
bmscomp commented on PR #13662:
URL: https://github.com/apache/kafka/pull/13662#issuecomment-1648586221
@divijvaidya after analysing the regression regarding Kafka code base, it
seems that the regression is related to records, and in the current version of
Kafka records are not introduced
ahuang98 opened a new pull request, #14084:
URL: https://github.com/apache/kafka/pull/14084
Adding latest versions to kafka_upgrade_test.py. Confirmed test passes on
the latest versions.
Nit: also added back `LATEST_3_6` definition which was removed in
https://github.com/apache/kafka/pul
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1272724945
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +193,212 @@ public boolean validateClientRack
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1272693494
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +191,224 @@ public boolean validateClientRack
splett2 closed pull request #13501: MINOR: Use `exists` instead of return in
DelayedFetch
URL: https://github.com/apache/kafka/pull/13501
--
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
jolshan merged PR #13707:
URL: https://github.com/apache/kafka/pull/13707
--
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.
lihaosky commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1272692608
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java:
##
@@ -268,24 +268,44 @@ public static class AssignmentCon
gharris1727 commented on PR #14064:
URL: https://github.com/apache/kafka/pull/14064#issuecomment-1648540605
> I think TSV is fine for the output format. It'd definitely help if we
added headers.
👍
> I also found it a bit difficult to parse with the plugin location being
liste
jolshan merged PR #14033:
URL: https://github.com/apache/kafka/pull/14033
--
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.
jolshan commented on PR #14033:
URL: https://github.com/apache/kafka/pull/14033#issuecomment-1648533713
Test failures look unrelated. 👍
--
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
mumrah commented on code in PR #14062:
URL: https://github.com/apache/kafka/pull/14062#discussion_r1272701730
##
metadata/src/main/java/org/apache/kafka/metadata/migration/KRaftMigrationDriver.java:
##
@@ -756,4 +745,109 @@ static KRaftMigrationOperationConsumer
countingOperati
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746624#comment-17746624
]
Proven Provenzano commented on KAFKA-15243:
---
I just want to make sure that it
[
https://issues.apache.org/jira/browse/KAFKA-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746622#comment-17746622
]
Federico Valeri commented on KAFKA-15239:
-
Hi [~showuon], thanks for raising thi
[
https://issues.apache.org/jira/browse/KAFKA-15242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-15242:
Component/s: streams
> FixedKeyProcessor testing is unusable
> ---
C0urante commented on code in PR #14079:
URL: https://github.com/apache/kafka/pull/14079#discussion_r1272633816
##
connect/runtime/src/test/java/org/apache/kafka/connect/integration/SinkConnectorsIntegrationTest.java:
##
@@ -309,6 +319,48 @@ public void testCooperativeConsumerPa
mjsax commented on code in PR #14030:
URL: https://github.com/apache/kafka/pull/14030#discussion_r1272606193
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java:
##
@@ -185,4 +193,212 @@ public boolean validateClientRack()
gharris1727 commented on code in PR #14064:
URL: https://github.com/apache/kafka/pull/14064#discussion_r1272626540
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -0,0 +1,399 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
gharris1727 commented on code in PR #14064:
URL: https://github.com/apache/kafka/pull/14064#discussion_r1272620934
##
tools/src/main/java/org/apache/kafka/tools/ConnectPluginPath.java:
##
@@ -0,0 +1,399 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1272624245
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundatio
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1272624245
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,454 @@
+/*
+ * Licensed to the Apache Software Foundatio
jolshan commented on code in PR #14067:
URL: https://github.com/apache/kafka/pull/14067#discussion_r1272621431
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -0,0 +1,448 @@
+/*
+ * Licensed to the Apache Software Foundatio
[
https://issues.apache.org/jira/browse/KAFKA-15168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kamal Chandraprakash updated KAFKA-15168:
-
Fix Version/s: 3.6.0
> Handle overlapping remote log segments in RemoteLogMetada
cmccabe commented on code in PR #13947:
URL: https://github.com/apache/kafka/pull/13947#discussion_r1272579577
##
core/src/main/scala/kafka/server/ReplicaManager.scala:
##
@@ -526,14 +532,17 @@ class ReplicaManager(val config: KafkaConfig,
/**
* Stop the given partitions.
cmccabe commented on PR #13947:
URL: https://github.com/apache/kafka/pull/13947#issuecomment-1648357381
We can't commit this without KRaft support. ZK mode is deprecated and we
cannot add new features there that don't exist in KRaft.
Leaving a -1 until this is addressed.
--
This is
kamalcph commented on code in PR #14049:
URL: https://github.com/apache/kafka/pull/14049#discussion_r1272573307
##
storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogMetadataManager.java:
##
@@ -201,4 +201,13 @@ void onPartitionLeadershipChanges(Set
l
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272573195
##
group-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java:
##
@@ -5402,6 +5412,14 @@ private Map> fromTopicPartitions(
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272561659
##
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json:
##
@@ -29,7 +29,20 @@
{ "name": "TopicName", "versions": "0+",
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272561274
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TopicMetadata.java:
##
@@ -40,23 +45,31 @@ public class TopicMetadata {
*/
p
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272558721
##
group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json:
##
@@ -29,7 +29,20 @@
{ "name": "TopicName", "versions": "0+",
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272557652
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/consumer/TargetAssignmentBuilder.java:
##
@@ -244,16 +244,21 @@ public TargetAssignmentResult bu
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272551436
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/PartitionMetadata.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Fou
rreddy-22 commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272550567
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/PartitionMetadata.java:
##
@@ -0,0 +1,85 @@
+/*
+ * Licensed to the Apache Software Fou
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746546#comment-17746546
]
Sergio Troiano commented on KAFKA-15243:
[~pprovenzano] we don't use KRaft yet,
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746544#comment-17746544
]
Proven Provenzano commented on KAFKA-15243:
---
Does this happen with KRaft?
> U
pprovenzano opened a new pull request, #14083:
URL: https://github.com/apache/kafka/pull/14083
This PR includes KRaft Metadata support for DelelegationTokens, updated
tests for DelegationTokens to run in Zk and KRaft mode, and a bump of the
metadata version specifically for DelelegationToke
pprovenzano closed pull request #13916: WIP DelegationToken Support for KRaft
URL: https://github.com/apache/kafka/pull/13916
--
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
dajac commented on code in PR #14033:
URL: https://github.com/apache/kafka/pull/14033#discussion_r127255
##
storage/src/main/java/org/apache/kafka/storage/internals/log/VerificationStateEntry.java:
##
@@ -58,14 +58,16 @@ public short epoch() {
}
/**
- * We ke
dajac commented on code in PR #13998:
URL: https://github.com/apache/kafka/pull/13998#discussion_r1272465513
##
checkstyle/import-control.xml:
##
@@ -48,6 +48,7 @@
+
Review Comment:
I suppose that we can remove this, isn't it?
##
group-coordinator/sr
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergio Troiano updated KAFKA-15243:
---
Component/s: core
> User creation mismatch
> --
>
> Key:
Sergio Troiano created KAFKA-15243:
--
Summary: User creation mismatch
Key: KAFKA-15243
URL: https://issues.apache.org/jira/browse/KAFKA-15243
Project: Kafka
Issue Type: Bug
Affects Versio
pgjbz closed pull request #13928: KAFKA-15097: prevent server shutdown when
source file not exists
URL: https://github.com/apache/kafka/pull/13928
--
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
mehbey closed pull request #13709: KAFKA-14991:Added a validation to check if
the record timestamp is in the future compared to the broker's timestamp
URL: https://github.com/apache/kafka/pull/13709
--
This is an automated message from the Apache Git Service.
To respond to the message, please
mehbey commented on PR #13709:
URL: https://github.com/apache/kafka/pull/13709#issuecomment-1648169813
Based on the the proposed implementation in the[
KIP](https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3A+Improve+Message+Timestamp+Validation)
closing this pull requests as we ar
OmniaGM opened a new pull request, #14082:
URL: https://github.com/apache/kafka/pull/14082
Waiting for a vote on KIP-949
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify
[
https://issues.apache.org/jira/browse/KAFKA-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-15237:
Description: In the scala code, we rely on `offsets.commit.timeout.ms` to
bound all the writes. We
[
https://issues.apache.org/jira/browse/KAFKA-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-15237:
Description: In the scala code, we rely on `offsets.commit.timeout.ms` to
bound all the writes. We
[
https://issues.apache.org/jira/browse/KAFKA-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot reassigned KAFKA-15237:
---
Assignee: David Jacot
> Implement write operation timeout
> ---
[
https://issues.apache.org/jira/browse/KAFKA-15237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot updated KAFKA-15237:
Summary: Implement write operation timeout (was: Implement
`offsets.commit.timeout.ms` setting)
satishd merged PR #14004:
URL: https://github.com/apache/kafka/pull/14004
--
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.
C0urante opened a new pull request, #14081:
URL: https://github.com/apache/kafka/pull/14081
We've started to see messages like this on startup:
> [2023-07-24 09:16:34,776] WARN Ignoring ambiguous alias 'Value' since it
refers to multiple distinct plugins
[org.apache.kafka.connect.tra
Zlstibor Veljkovic created KAFKA-15242:
--
Summary: FixedKeyProcessor testing is unusable
Key: KAFKA-15242
URL: https://issues.apache.org/jira/browse/KAFKA-15242
Project: Kafka
Issue Type:
C0urante commented on code in PR #14077:
URL: https://github.com/apache/kafka/pull/14077#discussion_r1272212887
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java:
##
@@ -108,7 +108,7 @@ public abstract class AbstractWorkerSourceTask
[
https://issues.apache.org/jira/browse/KAFKA-14112?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-14112:
--
Labels: needs-kip (was: )
> Expose replication-offset-lag Mirror metric
> ---
bmscomp commented on PR #14075:
URL: https://github.com/apache/kafka/pull/14075#issuecomment-1647817977
@divijvaidya Before those changes, the generation of tests jacoco coverage
report fails because of this error
`"Could not set unknown property 'enabled' for Report html of typ
showuon commented on PR #14051:
URL: https://github.com/apache/kafka/pull/14051#issuecomment-1647817568
Yes, I've rerun the CI build. Let's wait for the results.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
[
https://issues.apache.org/jira/browse/KAFKA-15235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Said BOUDJELDA updated KAFKA-15235:
---
Description:
On current dev branch, gradle 8.x fails while trying to generate test coverage
muralibasani commented on PR #13417:
URL: https://github.com/apache/kafka/pull/13417#issuecomment-1647813211
> Hi @muralibasani, thanks for the additional work. I left some comments.
>
> As @mimaison, I also think that it would be better to create a dedicated
PR for metadata and stora
1 - 100 of 149 matches
Mail list logo
