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
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":
[
https://issues.apache.org/jira/browse/KAFKA-15005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746774#comment-17746774
]
Sagar Rao commented on KAFKA-15005:
---
[~LucentWong], the PR for
[
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
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:
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:
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
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)
[
https://issues.apache.org/jira/browse/KAFKA-15240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746733#comment-17746733
]
shilin Lu commented on KAFKA-15240:
---
[~ijuma] [~junrao] please watch this issue，thank you!
>
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
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
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=17746711#comment-17746711
]
Ismael Juma commented on KAFKA-14969:
-
This is sort of done already:
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 {
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
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
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
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
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
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
[
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=17746667#comment-17746667
]
Said BOUDJELDA commented on KAFKA-14969:
Can I take this ticket, and prepare even the most
[
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
[
https://issues.apache.org/jira/browse/KAFKA-15235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746659#comment-17746659
]
Eike Thaden commented on KAFKA-15235:
-
@Said: Thank you for the additional explanation.
[
https://issues.apache.org/jira/browse/KAFKA-15214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746655#comment-17746655
]
Lixin Yao commented on KAFKA-15214:
---
Hi [~divijvaidya] , any further suggestion? Is that ok if I
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
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
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)
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
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
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
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
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:
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
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
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:
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
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
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746624#comment-17746624
]
Proven Provenzano commented on KAFKA-15243:
---
I just want to make sure that it works the same
[
https://issues.apache.org/jira/browse/KAFKA-15239?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746622#comment-17746622
]
Federico Valeri commented on KAFKA-15239:
-
Hi [~showuon], thanks for raising this.
QuotaTest
[
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
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
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
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
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
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
[
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
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
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
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
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":
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 {
*/
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":
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746546#comment-17746546
]
Sergio Troiano commented on KAFKA-15243:
[~pprovenzano] we don't use KRaft yet, so this is
[
https://issues.apache.org/jira/browse/KAFKA-15243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17746544#comment-17746544
]
Proven Provenzano commented on KAFKA-15243:
---
Does this happen with KRaft?
> User creation
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
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.
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
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?
##
[
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
> --
>
>
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
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
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,
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
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.
[
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.
[
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:
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
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
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
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
muralibasani commented on code in PR #13417:
URL: https://github.com/apache/kafka/pull/13417#discussion_r1272186536
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java:
##
@@ -230,6 +235,55 @@ public Optional serverConfigName(String
configName) {
divijvaidya commented on PR #14075:
URL: https://github.com/apache/kafka/pull/14075#issuecomment-1647805630
Please add how did you test this and the before/after results. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
1 - 100 of 151 matches
Mail list logo
