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
[
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
[
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=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=17619169#comment-17619169
]
Travis Bischel commented on KAFKA-14312:
My investigation for this issue comes f
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
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
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
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:
[
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
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
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
[
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
> --
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
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
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
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
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.
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(
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 #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
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
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 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
[
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
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:comment-tabpanel&focusedCommentId=17619024#comment-17619024
]
Divij Vaidya commented on KAFKA-14133:
--
[~shekharrajak] StreamsMetricsImlTest file
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-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-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
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-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
> -
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-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
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
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() {
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 #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
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
[
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
[
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
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
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-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
[
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
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
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 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
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
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)
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
[
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
57 matches
Mail list logo
