LinShunKang commented on PR #12683:
URL: https://github.com/apache/kafka/pull/12683#issuecomment-1262595051
> I re-run the test case in trunk as well as in your branch locally with
IDE, and both passes, so I think it's due to jenkins machines compute resource
limit itself.
>
> But I
divijvaidya commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r983849860
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -169,4 +181,140 @@ class ReplicaFetcherThread(name: String,
partition.truncateFullyAndStar
divijvaidya commented on code in PR #11390:
URL: https://github.com/apache/kafka/pull/11390#discussion_r983849860
##
core/src/main/scala/kafka/server/ReplicaFetcherThread.scala:
##
@@ -169,4 +181,140 @@ class ReplicaFetcherThread(name: String,
partition.truncateFullyAndStar
guozhangwang merged PR #12683:
URL: https://github.com/apache/kafka/pull/12683
--
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.ap
[
https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-4852:
-
Fix Version/s: 3.4.0
> ByteBufferSerializer not compatible with offsets
> ---
[
https://issues.apache.org/jira/browse/KAFKA-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14265:
---
Fix Version/s: 3.3.1
> Prefix ACLs may shadow other prefix ACLs
> --
[
https://issues.apache.org/jira/browse/KAFKA-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14265:
---
Affects Version/s: 3.3.0
> Prefix ACLs may shadow other prefix ACLs
[
https://issues.apache.org/jira/browse/KAFKA-14259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14259:
---
Affects Version/s: 3.3.0
> BrokerRegistration#toString throws an exc
[
https://issues.apache.org/jira/browse/KAFKA-14259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio updated KAFKA-14259:
---
Fix Version/s: 3.3.1
(was: 3.3.0)
> BrokerReg
[
https://issues.apache.org/jira/browse/KAFKA-14265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jose Armando Garcia Sancio resolved KAFKA-14265.
Resolution: Fixed
> Prefix ACLs may shadow other prefix ACLs
> ---
alexec commented on PR #12697:
URL: https://github.com/apache/kafka/pull/12697#issuecomment-1262651094
@mjsax can I please request review?
--
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 spec
alexec commented on PR #12698:
URL: https://github.com/apache/kafka/pull/12698#issuecomment-1262652496
@yeralin can I please request review from you as you know this code and are
a recent committer.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
alexec opened a new pull request, #12699:
URL: https://github.com/apache/kafka/pull/12699
Signed-off-by: Alex Collins
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping rev
alexec commented on PR #12698:
URL: https://github.com/apache/kafka/pull/12698#issuecomment-1262660882
Needs KIP.
--
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 unsubsc
Christopher Meier created KAFKA-14268:
-
Summary: When aggregating on a KGroupedStream allow an
InitializerWithKey
Key: KAFKA-14268
URL: https://issues.apache.org/jira/browse/KAFKA-14268
Project: K
eikemeier opened a new pull request, #12700:
URL: https://github.com/apache/kafka/pull/12700
Kafka Streams expects a version resource at
/kafka/kafka-streams-version.properties. It is read by `ClientMetrics`,
initialised by
https://github.com/apache/kafka/blob/3.3.0/streams/src/main
[
https://issues.apache.org/jira/browse/KAFKA-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611180#comment-17611180
]
Zach Fry commented on KAFKA-14267:
--
Upon some investigation, I wasn't able to find anyw
jsancio opened a new pull request, #12701:
URL: https://github.com/apache/kafka/pull/12701
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgra
jsancio merged PR #12701:
URL: https://github.com/apache/kafka/pull/12701
--
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.
jsancio opened a new pull request, #12702:
URL: https://github.com/apache/kafka/pull/12702
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgra
jsancio merged PR #12702:
URL: https://github.com/apache/kafka/pull/12702
--
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.
hachikuji opened a new pull request, #12703:
URL: https://github.com/apache/kafka/pull/12703
In https://github.com/apache/kafka/pull/12695, we discovered a gap in our
testing of `StandardAuthorizer`. We addressed the specific case that was
failing, but I think we need to establish a better
hachikuji merged PR #12669:
URL: https://github.com/apache/kafka/pull/12669
--
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.apach
[
https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611345#comment-17611345
]
Werner Daehn commented on KAFKA-4852:
-
Thanks!
> ByteBufferSerializer not compatible
[
https://issues.apache.org/jira/browse/KAFKA-4852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611351#comment-17611351
]
LinShunkang commented on KAFKA-4852:
That's all right : )
> ByteBufferSerializer not
urbandan commented on PR #12392:
URL: https://github.com/apache/kafka/pull/12392#issuecomment-1261958861
@jolshan It is an idea, the first version of the PR was trying to implement
that, but the current state of the PR is based on the fatal state.
The idea about keeping the producer i
divijvaidya commented on PR #12669:
URL: https://github.com/apache/kafka/pull/12669#issuecomment-1262126497
Test failures are unrelated.
> Build / JDK 17 and Scala 2.13 /
testTransactionAfterProducerIdExpires(String).quorum=zk -
kafka.api.TransactionsExpirationTest
> Build / JDK 1
divijvaidya commented on code in PR #12692:
URL: https://github.com/apache/kafka/pull/12692#discussion_r983414080
##
raft/src/main/java/org/apache/kafka/raft/VotedState.java:
##
@@ -92,11 +92,6 @@ public boolean hasElectionTimeoutExpired(long currentTimeMs)
{
return el
[
https://issues.apache.org/jira/browse/KAFKA-12946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17611018#comment-17611018
]
zhangzhisheng commented on KAFKA-12946:
---
upgrade 2.4.2
> __consumer_offsets topic
showuon commented on code in PR #12639:
URL: https://github.com/apache/kafka/pull/12639#discussion_r983504767
##
core/src/test/scala/unit/kafka/server/metadata/BrokerMetadataPublisherTest.scala:
##
@@ -178,15 +181,21 @@ class BrokerMetadataPublisherTest {
private def newMoc
showuon commented on PR #12639:
URL: https://github.com/apache/kafka/pull/12639#issuecomment-1262235095
@hachikuji , please take a look. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to th
Yu Wang created KAFKA-14266:
---
Summary: MirrorSourceTask will stop mirroring when get the corrupt
record
Key: KAFKA-14266
URL: https://issues.apache.org/jira/browse/KAFKA-14266
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Description:
The mirror task will keeping throwing this error when got a corrupt record
{code:java}
[2022-
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Issue Type: Bug (was: Improvement)
> MirrorSourceTask will stop mirroring when get the corrupt record
> -
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Summary: MirrorSourceTask will stop mirroring when get corrupt record
(was: MirrorSourceTask will stop mi
see-quick commented on code in PR #12692:
URL: https://github.com/apache/kafka/pull/12692#discussion_r983614070
##
raft/src/main/java/org/apache/kafka/raft/VotedState.java:
##
@@ -92,11 +92,6 @@ public boolean hasElectionTimeoutExpired(long currentTimeMs)
{
return elec
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Description:
The mirror task will keeping throwing this error when got a corrupt record
{code:java}
[2022-
[
https://issues.apache.org/jira/browse/KAFKA-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang updated KAFKA-14266:
Description:
The mirror task will keeping throwing this error when got a corrupt record
{code:java}
[2022-
szalapski commented on PR #5876:
URL: https://github.com/apache/kafka/pull/5876#issuecomment-1262375026
Would love to get this fixed. How can I help?
--
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-14266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yu Wang reassigned KAFKA-14266:
---
Assignee: Yu Wang
> MirrorSourceTask will stop mirroring when get corrupt record
>
alexec commented on PR #12694:
URL: https://github.com/apache/kafka/pull/12694#issuecomment-1262401939
Replaced by https://github.com/apache/kafka/pull/12697.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
alexec opened a new pull request, #12697:
URL: https://github.com/apache/kafka/pull/12697
Signed-off-by: Alex Collins
Fixes [KAFKA-2526](https://issues.apache.org/jira/browse/KAFKA-2526)
Configuration of the `ConsoleProducer` and `ConsoleConsumer` has been broken
since 2017. Despi
alexec closed pull request #12694: KAFKA-2526 : fix deserializer/serializer
from properties for console consume/producer
URL: https://github.com/apache/kafka/pull/12694
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
BrokenWingsIcarus commented on PR #9947:
URL: https://github.com/apache/kafka/pull/9947#issuecomment-1262432302
by casuse see [http
://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6728842](http://bugs.sun.com/bugdatabase/view_bug.do?bug_id=6728842)
--
This is an automated message from the
hachikuji commented on PR #12695:
URL: https://github.com/apache/kafka/pull/12695#issuecomment-1262460687
The build is failing due to the newly added test:
`kafka.api.AuthorizerIntegrationTest.testPrefixAcls(String).quorum=zk`
--
This is an automated message from the Apache Git Service.
T
alexec opened a new pull request, #12698:
URL: https://github.com/apache/kafka/pull/12698
Signed-off-by: Alex Collins
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping rev
cmccabe merged PR #12695:
URL: https://github.com/apache/kafka/pull/12695
--
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.
Zach Fry created KAFKA-14267:
Summary: CVE-2022-36944 - Scala deserialization bug
Key: KAFKA-14267
URL: https://issues.apache.org/jira/browse/KAFKA-14267
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-14267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zach Fry updated KAFKA-14267:
-
Description:
[https://nvd.nist.gov/vuln/detail/CVE-2022-36944]
This is marked as CRITICAL severity vuln
49 matches
Mail list logo
