[
https://issues.apache.org/jira/browse/KAFKA-14287?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617521#comment-17617521
]
Luke Chen commented on KAFKA-14287:
---
Thanks for the reply. But I don't know how we can
lucasbru commented on code in PR #12743:
URL: https://github.com/apache/kafka/pull/12743#discussion_r995065939
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -1481,6 +1481,36 @@ public void
shouldTryToLockValidTaskDirsAtRebalan
cadonna commented on code in PR #12743:
URL: https://github.com/apache/kafka/pull/12743#discussion_r995452727
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/TaskManagerTest.java:
##
@@ -1481,6 +1481,36 @@ public void
shouldTryToLockValidTaskDirsAtRebalanc
cadonna commented on code in PR #12743:
URL: https://github.com/apache/kafka/pull/12743#discussion_r995454259
##
streams/src/test/java/org/apache/kafka/streams/integration/SmokeTestDriverIntegrationTest.java:
##
@@ -42,18 +43,18 @@
import static org.apache.kafka.streams.tests.S
cadonna commented on code in PR #12465:
URL: https://github.com/apache/kafka/pull/12465#discussion_r995461375
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1096,7 +1096,7 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeout
showuon opened a new pull request, #12748:
URL: https://github.com/apache/kafka/pull/12748
KIP-792
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (includin
conradlco commented on PR #12688:
URL: https://github.com/apache/kafka/pull/12688#issuecomment-1278739819
@ijuma - hi Ismael, I just went to the main branch readme:
https://github.com/apache/kafka#readme and this now has a broken link to this
deleted readme, cheers.
--
This is an automat
showuon commented on PR #12688:
URL: https://github.com/apache/kafka/pull/12688#issuecomment-1278745345
@conradlco , nice find. Are you interested in submitting a PR to fix it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
shekhar-rajak commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1278750513
Not sure why these checks failed. These failures are not looking relevant.
Please someone help.
--
This is an automated message from the Apache Git Service.
To respond to the me
Damien Gasparina created KAFKA-14302:
Summary: Infinite probing rebalance if a changelog topic got
emptied
Key: KAFKA-14302
URL: https://issues.apache.org/jira/browse/KAFKA-14302
Project: Kafka
Igor Soarez created KAFKA-14303:
---
Summary: Producer.send without record key and batch.size=0 goes
into infinite loop
Key: KAFKA-14303
URL: https://issues.apache.org/jira/browse/KAFKA-14303
Project: Kafk
[
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-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617666#comment-17617666
]
Igor Soarez commented on KAFKA-14303:
-
The issue can be more specifically replicated
vamossagar12 commented on code in PR #12561:
URL: https://github.com/apache/kafka/pull/12561#discussion_r995680008
##
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinatorIncrementalTest.java:
##
@@ -517,13 +517,13 @@ public void testTaskAs
[
https://issues.apache.org/jira/browse/KAFKA-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617696#comment-17617696
]
Luke Chen commented on KAFKA-14303:
---
[~soarez] , thanks for reporting the issue. Looks
shekhar-rajak commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1278946808
Failing tests seem unrelated
[
kafka.admin.ResetConsumerGroupOffsetTest.testResetOffsetsToZonedDateTime,
kafka.admin.MetadataQuorumCommandTest.testDescribeQuorumReplica
shekhar-rajak commented on PR #12735:
URL: https://github.com/apache/kafka/pull/12735#issuecomment-1278951012
Failing tests seem unrelated
[
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest.testReplication()
KStream
]
--
This is an automated m
shekhar-rajak commented on PR #12735:
URL: https://github.com/apache/kafka/pull/12735#issuecomment-1278952145
Thanks @divijvaidya for the review. I have updated the PR.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
shekhar-rajak commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1278966484
Thanks @guozhangwang for the review. I have updated the PR, please have a
look.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
shekhar-rajak commented on PR #12739:
URL: https://github.com/apache/kafka/pull/12739#issuecomment-1278967518
Ping for the PR review @C0urante
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
[
https://issues.apache.org/jira/browse/KAFKA-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617712#comment-17617712
]
Igor Soarez commented on KAFKA-14303:
-
[~showuon] Yes, I'm currently investigating
[
https://issues.apache.org/jira/browse/KAFKA-14303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Igor Soarez reassigned KAFKA-14303:
---
Assignee: Igor Soarez
> Producer.send without record key and batch.size=0 goes into infinit
[
https://issues.apache.org/jira/browse/KAFKA-14133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617714#comment-17617714
]
Shekhar Prasad Rajak commented on KAFKA-14133:
--
Please help in PR review:
lucasbru opened a new pull request, #12749:
URL: https://github.com/apache/kafka/pull/12749
StreamThread in state PARTITIONS_ASSIGNED was running in
a busy loop until restoration is finished, stealing CPU
cycles from restoration and other StreamThreads on the machine.
Added unit
ijuma opened a new pull request, #12750:
URL: https://github.com/apache/kafka/pull/12750
Also moved KRaft mode above zk mode.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Ver
ijuma commented on PR #12688:
URL: https://github.com/apache/kafka/pull/12688#issuecomment-1279035666
Since I broke this, I went ahead and submitted a PR
https://github.com/apache/kafka/pull/12750
Thanks for flagging this @conradlco .
--
This is an automated message from the Apache
ijuma commented on PR #12657:
URL: https://github.com/apache/kafka/pull/12657#issuecomment-1279038561
Very nice, thanks for improving this!
--
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 spe
ijuma commented on code in PR #12734:
URL: https://github.com/apache/kafka/pull/12734#discussion_r995790517
##
core/src/main/scala/kafka/cluster/Partition.scala:
##
@@ -1339,6 +1341,26 @@ class Partition(val topicPartition: TopicPartition,
}
}
+// Fetching from
ijuma opened a new pull request, #12751:
URL: https://github.com/apache/kafka/pull/12751
This was helpful when debugging an issue recently.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build statu
ijuma commented on PR #12148:
URL: https://github.com/apache/kafka/pull/12148#issuecomment-1279058422
@omkreddy Rebased.
--
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
ijuma commented on PR #12666:
URL: https://github.com/apache/kafka/pull/12666#issuecomment-1279069434
I think there's no way around the junit extension, but I was wondering if we
could use that with the `Exit` classes versus the security manager approach.
Then we don't have to depend on the
ijuma commented on PR #12621:
URL: https://github.com/apache/kafka/pull/12621#issuecomment-1279070040
cc @rondagostino
--
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 u
soarez opened a new pull request, #12752:
URL: https://github.com/apache/kafka/pull/12752
This fixes an bug which causes a call to producer.send(record) with a record
without a key and configured with batch.size=0 never to return.
Without specifying a key or a custom partitioner the n
wcarlson5 commented on code in PR #12465:
URL: https://github.com/apache/kafka/pull/12465#discussion_r995860323
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1096,7 +1096,7 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeout
lucasbru commented on PR #12749:
URL: https://github.com/apache/kafka/pull/12749#issuecomment-1279148211
@guozhangwang @cadonna Do you want to have a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
soarez commented on PR #12752:
URL: https://github.com/apache/kafka/pull/12752#issuecomment-1279151952
@artemlivshits could you take a look at this one?
--
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
jsancio commented on code in PR #11023:
URL: https://github.com/apache/kafka/pull/11023#discussion_r995913999
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -778,9 +778,10 @@ public Future send(ProducerRecord
record) {
/**
* Asyn
[
https://issues.apache.org/jira/browse/KAFKA-14080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617865#comment-17617865
]
Philip Bourke commented on KAFKA-14080:
---
same issue as https://issues.apache.org/j
cadonna commented on PR #12743:
URL: https://github.com/apache/kafka/pull/12743#issuecomment-1279253105
Some failures regarding `SmokeTestDriverIntegrationTest` seem related.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
cadonna commented on code in PR #12465:
URL: https://github.com/apache/kafka/pull/12465#discussion_r995964228
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1096,7 +1096,7 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeout
cadonna commented on code in PR #12465:
URL: https://github.com/apache/kafka/pull/12465#discussion_r995965165
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1096,7 +1096,7 @@ private Optional removeStreamThread(final long
timeoutMs) throws Timeout
David Arthur created KAFKA-14304:
Summary: ZooKeeper to KRaft Migration
Key: KAFKA-14304
URL: https://issues.apache.org/jira/browse/KAFKA-14304
Project: Kafka
Issue Type: New Feature
jsancio commented on code in PR #12750:
URL: https://github.com/apache/kafka/pull/12750#discussion_r996023706
##
README.md:
##
@@ -83,15 +83,17 @@ fail due to code changes. You can just run:
./gradlew processMessages processTestMessages
+### Running a Kafka broker in K
jsancio merged PR #12707:
URL: https://github.com/apache/kafka/pull/12707
--
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.
David Arthur created KAFKA-14305:
Summary: KRaft Metadata Transactions
Key: KAFKA-14305
URL: https://issues.apache.org/jira/browse/KAFKA-14305
Project: Kafka
Issue Type: New Feature
Scanteianu opened a new pull request, #12753:
URL: https://github.com/apache/kafka/pull/12753
*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 reviewers.*
Add comments to
[
https://issues.apache.org/jira/browse/KAFKA-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-14298:
Description:
Getting null pointer exception.
{noformat}
java.lang.NullPointerException
at
org
[
https://issues.apache.org/jira/browse/KAFKA-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17617967#comment-17617967
]
Greg Harris commented on KAFKA-14298:
-
[~ramkychowdary0560] I'm not familiar with `c
[
https://issues.apache.org/jira/browse/KAFKA-14298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Harris updated KAFKA-14298:
Component/s: clients
(was: KafkaConnect)
> Getting null pointer exception
> -
soarez commented on PR #12752:
URL: https://github.com/apache/kafka/pull/12752#issuecomment-1279487116
Failing tests are unrelated:
```
:clients:unitTest CooperativeStickyAssignorTest >
testLargeAssignmentAndGroupWithNonEqualSubscription()
:clients:unitTest StickyAssignorTest >
soarez commented on PR #12752:
URL: https://github.com/apache/kafka/pull/12752#issuecomment-1279487451
@showuon @ijuma should this one also be backported to 3.3?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
ijuma commented on code in PR #12752:
URL: https://github.com/apache/kafka/pull/12752#discussion_r996190731
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/BuiltInPartitioner.java:
##
@@ -56,6 +56,9 @@ public class BuiltInPartitioner {
public BuiltInPar
ijuma commented on code in PR #12752:
URL: https://github.com/apache/kafka/pull/12752#discussion_r996192499
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java:
##
@@ -127,7 +127,9 @@ public RecordAccumulator(LogContext logContext,
guozhangwang merged PR #12744:
URL: https://github.com/apache/kafka/pull/12744
--
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
guozhangwang opened a new pull request, #12754:
URL: https://github.com/apache/kafka/pull/12754
0. Add name to task executors.
1. DefaultTaskManager implementation, for interacting with the TaskExecutors
and support add/remove/lock APIs.
2. Related unit tests.
### Committer Chec
guozhangwang merged PR #12754:
URL: https://github.com/apache/kafka/pull/12754
--
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
56 matches
Mail list logo