[
https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damien Gasparina updated KAFKA-14302:
-
Description:
If a store, with a changelog topic, has been fully emptied, it could genera
[
https://issues.apache.org/jira/browse/KAFKA-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damien Gasparina updated KAFKA-14302:
-
Description:
If a store, with a changelog topic, has been fully emptied, it could genera
Luke Chen created KAFKA-14308:
-
Summary: metadata shell might not need to handle leader change
message
Key: KAFKA-14308
URL: https://issues.apache.org/jira/browse/KAFKA-14308
Project: Kafka
Issu
showuon commented on code in PR #12711:
URL: https://github.com/apache/kafka/pull/12711#discussion_r996824526
##
metadata/src/main/java/org/apache/kafka/metadata/util/SnapshotFileReader.java:
##
@@ -131,6 +132,10 @@ private void handleControlBatch(FileChannelRecordBatch
batch)
showuon commented on PR #12711:
URL: https://github.com/apache/kafka/pull/12711#issuecomment-1280561793
@dengziming @jsancio , thanks for the comments. Adding tests for
`MetadataShell` now. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, ple
mdedetrich commented on PR #12675:
URL: https://github.com/apache/kafka/pull/12675#issuecomment-1280633531
So I managed to solve one problem but created another. So I have solved the
issues with the zinc incremental compiler (it appears that the version of zinc
was too old for the new Scala
mdedetrich commented on PR #12755:
URL: https://github.com/apache/kafka/pull/12755#issuecomment-1280635868
This is unrelated, closing.
--
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
mdedetrich closed pull request #12755: MINOR; Remove zinc workaround
URL: https://github.com/apache/kafka/pull/12755
--
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 unsubscr
[
https://issues.apache.org/jira/browse/KAFKA-14255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618868#comment-17618868
]
David Jacot commented on KAFKA-14255:
-
Raised the following tickets for impacted cli
[
https://issues.apache.org/jira/browse/KAFKA-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618871#comment-17618871
]
maayan shani commented on KAFKA-14306:
--
[~dengziming] Hi, the kafka protocol can co
divijvaidya commented on PR #12735:
URL: https://github.com/apache/kafka/pull/12735#issuecomment-1280883898
I almost forgot to mention @shekhar-rajak , you will need to remove the test
from the block list here:
https://github.com/apache/kafka/blob/trunk/build.gradle#L409 since it can now
w
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14132:
-
Description:
{color:#de350b}Some of the tests below use EasyMock as well. For those migrate
bot
shekhar-rajak commented on PR #12735:
URL: https://github.com/apache/kafka/pull/12735#issuecomment-1280899123
> I almost forgot to mention @shekhar-rajak , you will need to remove the
test from the block list here:
https://github.com/apache/kafka/blob/trunk/build.gradle#L409 since it can no
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14132:
-
Description:
{color:#de350b}Some of the tests below use EasyMock as well. For those migrate
bot
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14132:
-
Description:
{color:#de350b}Some of the tests below use EasyMock as well. For those migrate
bot
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14132:
-
Description:
{color:#de350b}Some of the tests below use EasyMock as well. For those migrate
bot
[
https://issues.apache.org/jira/browse/KAFKA-8350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17618948#comment-17618948
]
Mark Robert Miller commented on KAFKA-8350:
---
Yup. Log spam attack, attempts lef
ijuma merged PR #12751:
URL: https://github.com/apache/kafka/pull/12751
--
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
cadonna commented on code in PR #12749:
URL: https://github.com/apache/kafka/pull/12749#discussion_r997214392
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java:
##
@@ -2927,7 +2927,30 @@ void runOnce() {
@Test
public void sho
cadonna commented on code in PR #12524:
URL: https://github.com/apache/kafka/pull/12524#discussion_r997292607
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java:
##
@@ -313,36 +282,29 @@ public void shouldNotFlushAndThrowOnCloseDirty() {
cadonna commented on code in PR #12524:
URL: https://github.com/apache/kafka/pull/12524#discussion_r997292607
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java:
##
@@ -313,36 +282,29 @@ public void shouldNotFlushAndThrowOnCloseDirty() {
cadonna commented on code in PR #12524:
URL: https://github.com/apache/kafka/pull/12524#discussion_r997296305
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StandbyTaskTest.java:
##
@@ -313,36 +282,29 @@ public void shouldNotFlushAndThrowOnCloseDirty() {
ashmeet13 commented on PR #12684:
URL: https://github.com/apache/kafka/pull/12684#issuecomment-1281173832
Hi @vvcephei, bumping this PR up in case it got missed. Could please have a
look at this?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14133:
-
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put t
divijvaidya commented on code in PR #12739:
URL: https://github.com/apache/kafka/pull/12739#discussion_r997087704
##
streams/src/test/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingPersistentWindowStoreTest.java:
##
@@ -1159,58 +1183,42 @@ public void
shouldNot
[
https://issues.apache.org/jira/browse/KAFKA-4107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-4107:
Assignee: Chris Egerton
> Support offset reset capability in Kafka Connect
> -
lucasbru commented on PR #12743:
URL: https://github.com/apache/kafka/pull/12743#issuecomment-1281204100
I removed the integration test, because more fixes are needed to make it
work and I do not want to put them all in one PR. I will bring it back later.
--
This is an automated message f
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14133:
-
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put t
[
https://issues.apache.org/jira/browse/KAFKA-14132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14132:
-
Description:
{color:#de350b}Some of the tests below use EasyMock as well. For those migrate
bot
lucasbru commented on code in PR #12749:
URL: https://github.com/apache/kafka/pull/12749#discussion_r997333119
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java:
##
@@ -2927,7 +2927,30 @@ void runOnce() {
@Test
public void sh
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619024#comment-17619024
]
Divij Vaidya commented on KAFKA-14133:
--
[~shekharrajak] StreamsMetricsImlTest file
lucasbru commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1281213000
Failures look largely unrelated. However, `SmokeTestDriverIntegrationTest`
fails - so since this code path wasn't modified here, it looks like it is
already flaky in `trunk`.
--
This
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Divij Vaidya updated KAFKA-14133:
-
Description:
{color:#de350b}There are tests which use both PowerMock and EasyMock. I have
put t
vjanelle opened a new pull request, #12759:
URL: https://github.com/apache/kafka/pull/12759
Backporting changes for apache kafka 2.8.2, pulling in changes from
apache/kafka/#12675
*More detailed description of your change,
if necessary. The PR title and PR message become
the squ
vjanelle closed pull request #12759: 2.13.10 update for apache kafka 2.8.2
URL: https://github.com/apache/kafka/pull/12759
--
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 un
vjanelle commented on PR #12675:
URL: https://github.com/apache/kafka/pull/12675#issuecomment-1281287366
@mdedetrich https://github.com/vjanelle/kafka/tree/2.8.2-scalaupdate - thank
you 🙇
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
divijvaidya commented on code in PR #12465:
URL: https://github.com/apache/kafka/pull/12465#discussion_r997374051
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1096,7 +1096,7 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeo
soarez commented on code in PR #12752:
URL: https://github.com/apache/kafka/pull/12752#discussion_r997378161
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -127,7 +127,9 @@ public RecordAccumulator(LogContext logContext,
divijvaidya commented on code in PR #12684:
URL: https://github.com/apache/kafka/pull/12684#discussion_r997381071
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java:
##
@@ -1447,6 +1450,11 @@ private int updateMinSupportedVersion(
jsancio merged PR #12610:
URL: https://github.com/apache/kafka/pull/12610
--
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.
cadonna commented on code in PR #12465:
URL: https://github.com/apache/kafka/pull/12465#discussion_r997406087
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1096,7 +1096,7 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeout
Lucas Brutschy created KAFKA-14309:
--
Summary: Kafka Streams upgrade tests do not cover for FK-joins
Key: KAFKA-14309
URL: https://issues.apache.org/jira/browse/KAFKA-14309
Project: Kafka
Iss
lucasbru opened a new pull request, #12760:
URL: https://github.com/apache/kafka/pull/12760
The streams upgrade system inserted FK join code for every version of the
the StreamsUpgradeTest except for the latest. Also, the original code never
switched on the `test.run_fk_join` flag for the t
jonathan-albrecht-ibm commented on PR #12343:
URL: https://github.com/apache/kafka/pull/12343#issuecomment-1281468382
I have rebased this PR to latest trunk. I don't think the tests that failed
are related to these changes. Would it be possible for someone to review?
--
This is an automat
[
https://issues.apache.org/jira/browse/KAFKA-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-14309:
--
Assignee: Lucas Brutschy
> Kafka Streams upgrade tests do not cover for FK-joins
> --
jsancio opened a new pull request, #12761:
URL: https://github.com/apache/kafka/pull/12761
TODO!!
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including
hachikuji merged PR #12738:
URL: https://github.com/apache/kafka/pull/12738
--
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-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619146#comment-17619146
]
JosĂ© Armando GarcĂa Sancio commented on KAFKA-14178:
They should con
JosĂ© Armando GarcĂa Sancio created KAFKA-14310:
--
Summary: EventQueueTimeMs is incorrent for delayed events
Key: KAFKA-14310
URL: https://issues.apache.org/jira/browse/KAFKA-14310
Project:
Greg Harris created KAFKA-14311:
---
Summary: Connect Worker clean shutdown does not cleanly stop
connectors/tasks
Key: KAFKA-14311
URL: https://issues.apache.org/jira/browse/KAFKA-14311
Project: Kafka
Travis Bischel created KAFKA-14312:
--
Summary: Kraft + ProducerStateManager: produce requests to new
partitions with a non-zero sequence number should be rejected
Key: KAFKA-14312
URL: https://issues.apache.org/ji
Travis Bischel created KAFKA-14313:
--
Summary: Kraft: immediately producing to new topics occasionally
returns NOT_LEADER_FOR_PARTITION
Key: KAFKA-14313
URL: https://issues.apache.org/jira/browse/KAFKA-14313
[
https://issues.apache.org/jira/browse/KAFKA-14312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619169#comment-17619169
]
Travis Bischel commented on KAFKA-14312:
My investigation for this issue comes f
[
https://issues.apache.org/jira/browse/KAFKA-14312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619180#comment-17619180
]
Justine Olshan commented on KAFKA-14312:
Not sure if this is what you were sayin
[
https://issues.apache.org/jira/browse/KAFKA-14312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619180#comment-17619180
]
Justine Olshan edited comment on KAFKA-14312 at 10/18/22 1:22 AM:
[
https://issues.apache.org/jira/browse/KAFKA-14312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619197#comment-17619197
]
Travis Bischel commented on KAFKA-14312:
Agreed, the comment indicates another s
dengziming merged PR #12272:
URL: https://github.com/apache/kafka/pull/12272
--
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.apac
57 matches
Mail list logo