socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638494789
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,22 @@ private QuorumStateData readStateFromFile(File file
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638499447
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -67,7 +68,7 @@ public FileBasedStateStore(final File stateFile) {
socutes commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638494789
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,22 @@ private QuorumStateData readStateFromFile(File file
KahnCheny commented on pull request #10746:
URL: https://github.com/apache/kafka/pull/10746#issuecomment-847563816
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 the specific comment.
F
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Yurchenko reassigned KAFKA-12430:
--
Assignee: (was: Ivan Yurchenko)
> emit.heartbeats.enabled = false should disable
[
https://issues.apache.org/jira/browse/KAFKA-12430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ivan Yurchenko updated KAFKA-12430:
---
Description: Currently, whether MirrorMaker 2's
{{MirrorHeartbeatConnector}} emits heartbeat
vahidhashemian commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r638437845
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -637,19 +709,27 @@ private void
KahnCheny commented on pull request #10746:
URL: https://github.com/apache/kafka/pull/10746#issuecomment-847490202
> @KahnCheny , thanks for the PR. LGTM! Could you also remove the `public`
keyword in `ConsumerInterceptor` ? Thank you.
Of course.
--
This is an automated message f
showuon commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r638426531
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/TaskMetadata.java
##
@@ -40,6 +40,18 @@
private final Optional timeCurrentI
showuon commented on a change in pull request #10749:
URL: https://github.com/apache/kafka/pull/10749#discussion_r638422416
##
File path: raft/src/main/java/org/apache/kafka/raft/FileBasedStateStore.java
##
@@ -91,14 +92,22 @@ private QuorumStateData readStateFromFile(File file
ableegoldman commented on pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#issuecomment-847495713
All tests passed except for unrelated flaky
`kafka.connect.integration.RebalanceSourceConnectorsIntegrationTest.testRemovingWorker()`
--
This is an automated message from
Pedro Gontijo created KAFKA-12845:
-
Summary: Rollback change which requires join key to be non null on
KStream->GlobalKTable
Key: KAFKA-12845
URL: https://issues.apache.org/jira/browse/KAFKA-12845
Pro
ableegoldman commented on a change in pull request #10609:
URL: https://github.com/apache/kafka/pull/10609#discussion_r638396898
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -387,18 +422,18 @@ public synchronized vo
ableegoldman edited a comment on pull request #10609:
URL: https://github.com/apache/kafka/pull/10609#issuecomment-845638871
Rebased after the TaskId changes in KIP-470, and responded to all comments.
Not much has changed since the last review, just cleaning up here and there.
~It's pretty
sasukerui closed pull request #10751:
URL: https://github.com/apache/kafka/pull/10751
--
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.
For queries about this service, plea
ableegoldman commented on pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#issuecomment-847442114
cc @mjsax
--
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 comm
ableegoldman merged pull request #10690:
URL: https://github.com/apache/kafka/pull/10690
--
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.
For queries about this service, p
[
https://issues.apache.org/jira/browse/KAFKA-12835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350684#comment-17350684
]
Justine Olshan commented on KAFKA-12835:
Hi [~ivanyu]. Previously we could lose
ableegoldman edited a comment on pull request #10690:
URL: https://github.com/apache/kafka/pull/10690#issuecomment-847413919
Some unrelated test failures in `RaftClusterTest`,
`connect.integration.RebalanceSourceConnectorsIntegrationTest.testDeleteConnector()`,
and
`kafka.api.Plaintext
ableegoldman commented on pull request #10690:
URL: https://github.com/apache/kafka/pull/10690#issuecomment-847413919
Some unrelated test failures in `RaftClusterTest`,
`connect.integration.RebalanceSourceConnectorsIntegrationTest.testDeleteConnector()`,
and
`kafka.api.PlaintextConsume
ijuma closed pull request #10497:
URL: https://github.com/apache/kafka/pull/10497
--
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.
For queries about this service, please c
ableegoldman commented on a change in pull request #10755:
URL: https://github.com/apache/kafka/pull/10755#discussion_r638336725
##
File path: streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java
##
@@ -80,6 +83,35 @@ public String toString() {
return n
ableegoldman opened a new pull request #10755:
URL: https://github.com/apache/kafka/pull/10755
Quick followup to KIP-740. I also noticed the TaskId#parse method had been
modified previously, and should be re-added to the public TaskId class. It also
had no tests, so now it does
--
A. Sophie Blee-Goldman created KAFKA-12844:
--
Summary: KIP-740 follow up: clean up TaskId
Key: KAFKA-12844
URL: https://issues.apache.org/jira/browse/KAFKA-12844
Project: Kafka
Issue
A. Sophie Blee-Goldman created KAFKA-12843:
--
Summary: KIP-740 follow up: clean up TaskMetadata
Key: KAFKA-12843
URL: https://issues.apache.org/jira/browse/KAFKA-12843
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350654#comment-17350654
]
Ryan Cabral commented on KAFKA-12838:
-
Yes, increasing the number of partitions can
jolshan commented on pull request #10754:
URL: https://github.com/apache/kafka/pull/10754#issuecomment-847389546
Hmm looks like `KafkaMetadataLogTest.testTopicId` is failing because we set
`keepPartitionMetadataFile` to be false. When I ensure that we only assign
topicId when `keepPartitio
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350650#comment-17350650
]
A. Sophie Blee-Goldman commented on KAFKA-9168:
---
Yep, all the rocksdb work
junrao commented on a change in pull request #10684:
URL: https://github.com/apache/kafka/pull/10684#discussion_r638164890
##
File path: core/src/main/scala/kafka/log/LogSegments.scala
##
@@ -210,11 +209,23 @@ class LogSegments(topicPartition: TopicPartition) {
* @return th
jolshan opened a new pull request #10754:
URL: https://github.com/apache/kafka/pull/10754
Upon upgrading to IBP 2.8, topic ID can end up getting reassigned which can
cause errors in LeaderAndIsr handling when the partition metadata files from
the previous ID are still on the broker.
[
https://issues.apache.org/jira/browse/KAFKA-12838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350606#comment-17350606
]
Ryanne Dolan commented on KAFKA-12838:
--
Would it help to significantly increase the
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657442
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java
##
@@ -45,34 +45,30 @@ public void setIfUnset(fin
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657442
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java
##
@@ -45,34 +45,30 @@ public void setIfUnset(fin
cmccabe opened a new pull request #10753:
URL: https://github.com/apache/kafka/pull/10753
Support the KIP-455 reassignment API when in KRaft mode. Reassignments
which merely rearrange partitions complete immediately. Those that only
remove a partition complete immediately if the ISR wo
mumrah opened a new pull request #10752:
URL: https://github.com/apache/kafka/pull/10752
This is part 2 of
[KIP-730](https://cwiki.apache.org/confluence/display/KAFKA/KIP-730%3A+Producer+ID+generation+in+KRaft+mode),
part 1 was in #10504.
This PR adds support on the KRaft controller
junrao merged pull request #10742:
URL: https://github.com/apache/kafka/pull/10742
--
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.
For queries about this service, please
[
https://issues.apache.org/jira/browse/KAFKA-8522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350551#comment-17350551
]
Jun Rao commented on KAFKA-8522:
latest PR link
> Tombstones can survive forever
> -
dejan2609 commented on pull request #10698:
URL: https://github.com/apache/kafka/pull/10698#issuecomment-847201180
CheckStyle team (@romani) needs this in order to add Kafka project into
their regression suit here:
https://github.com/checkstyle/contribution/blob/master/checkstyle-teste
dejan2609 edited a comment on pull request #10698:
URL: https://github.com/apache/kafka/pull/10698#issuecomment-847174293
If I may ask you @showuon: do we need to ping someone else for another
review (or for merge into trunk) ?
_Edit (just to answer to my self): there are two types
dejan2609 commented on pull request #10698:
URL: https://github.com/apache/kafka/pull/10698#issuecomment-847174293
If I may ask you @showuon: do we need to ping someone else for another
review (or for merge into trunk) ?
--
This is an automated message from the Apache Git Service.
To re
dengziming commented on pull request #10751:
URL: https://github.com/apache/kafka/pull/10751#issuecomment-847135527
iif means if and only if
--
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 t
vvcephei commented on pull request #10744:
URL: https://github.com/apache/kafka/pull/10744#issuecomment-847118811
Filed ticket for Connect test:
https://issues.apache.org/jira/browse/KAFKA-12842
Commented on ticket for Raft test:
https://issues.apache.org/jira/browse/KAFKA-12629
--
T
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-12629:
-
Summary: Failing Test: RaftClusterTest (was: Flaky Test RaftClusterTest)
> Failing Test: RaftCl
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350483#comment-17350483
]
John Roesler edited comment on KAFKA-12629 at 5/24/21, 3:22 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-12677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-12677:
-
Fix Version/s: 3.0.0
> The raftCluster always send to the wrong active controller and never upda
[
https://issues.apache.org/jira/browse/KAFKA-12677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-12677:
-
Priority: Blocker (was: Major)
> The raftCluster always send to the wrong active controller and
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-12629:
-
Priority: Blocker (was: Critical)
> Flaky Test RaftClusterTest
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-12629:
-
Fix Version/s: 3.0.0
> Flaky Test RaftClusterTest
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350483#comment-17350483
]
John Roesler commented on KAFKA-12629:
--
Failed also on:
[https://github.com/apache
John Roesler created KAFKA-12842:
Summary: Failing test:
org.apache.kafka.connect.integration.ConnectWorkerIntegrationTest.testSourceTaskNotBlockedOnShutdownWithNonExistentTopic
Key: KAFKA-12842
URL: https://issue
sasukerui opened a new pull request #10751:
URL: https://github.com/apache/kafka/pull/10751
fix typo
--
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.
For queries about this
showuon commented on pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#issuecomment-847042383
@vahidhashemian , thanks for your comments. I've updated. Please take a look
again. Thank you.
--
This is an automated message from the Apache Git Service.
To respond to the m
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r637943535
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -80,9 +80,7 @@ public MemberData(List p
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r637941574
##
File path:
clients/src/test/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignorTest.java
##
@@ -598,6 +555,43 @@ public void
test
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r637939950
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -384,37 +326,39 @@ private boolean allS
showuon commented on a change in pull request #10552:
URL: https://github.com/apache/kafka/pull/10552#discussion_r637936879
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java
##
@@ -444,23 +392,32 @@ private boolean allS
[
https://issues.apache.org/jira/browse/KAFKA-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350413#comment-17350413
]
loboxu commented on KAFKA-12333:
[~jsancio] The problem seems to have been fixed, right?
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657442
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java
##
@@ -45,34 +45,30 @@ public void setIfUnset(fin
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657442
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java
##
@@ -45,34 +45,30 @@ public void setIfUnset(fin
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657657
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java
##
@@ -90,14 +90,19 @@ public void process(fin
ayoukhananov commented on pull request #10728:
URL: https://github.com/apache/kafka/pull/10728#issuecomment-846970648
@showuon Thanks for your feedback.
1. NPE happened in our Prod env .
I miss the part of Jira ticket and added now this
[Ticket](https://issues.apache.org/jira/br
Avi Youkhananov created KAFKA-12841:
---
Summary: NPE from the provided metadata in client callback in case
of ApiException
Key: KAFKA-12841
URL: https://issues.apache.org/jira/browse/KAFKA-12841
Proje
fqaiser94 commented on a change in pull request #10747:
URL: https://github.com/apache/kafka/pull/10747#discussion_r637657442
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java
##
@@ -45,34 +45,30 @@ public void setIfUnset(fin
DuongPTIT opened a new pull request #10750:
URL: https://github.com/apache/kafka/pull/10750
Getting NegativeArraySizeException when using Kafka Connect to send data to
Kafka on Kafka version 2.5
PTAL @huxihx @kkonstantine . Many thanks.
### Committer Checklist (excluded from c
David Jacot created KAFKA-12840:
---
Summary: Removing `compact` cleaning on a topic should abort
on-going compactions
Key: KAFKA-12840
URL: https://issues.apache.org/jira/browse/KAFKA-12840
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-12835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350330#comment-17350330
]
Ivan Yurchenko commented on KAFKA-12835:
bq. I was curious about your upgrade pr
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pham Huy Hoang updated KAFKA-8120:
--
Comment: was deleted
(was: Hi [~wj1918], I tried to test as your above steps. However, I got an
[
https://issues.apache.org/jira/browse/KAFKA-12461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
loboxu reassigned KAFKA-12461:
--
Assignee: loboxu
> Extend LogManager to cover the metadata topic
> --
[
https://issues.apache.org/jira/browse/KAFKA-8120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350289#comment-17350289
]
Pham Huy Hoang commented on KAFKA-8120:
---
Hi [~wj1918], I tried to test as your abov
[
https://issues.apache.org/jira/browse/KAFKA-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350279#comment-17350279
]
Luke Chen commented on KAFKA-12805:
---
[~nicolas.guyomar], I tried to set the
{{[reque
[
https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17350274#comment-17350274
]
loboxu commented on KAFKA-12773:
[~jagsancio] Could you please tell me the name of you
socutes opened a new pull request #10749:
URL: https://github.com/apache/kafka/pull/10749
The raft module may not be fully consistent on this but in general in that
module we have decided to not throw the checked IOException. We have been
avoiding checked IOException exceptions by wrapping
72 matches
Mail list logo