[
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
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
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
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
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
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
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
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
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,
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
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,
[
https://issues.apache.org/jira/browse/KAFKA-12835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350684#comment-17350684
]
Justine Olshan commented on KAFKA-12835:
Hi [~ivanyu]. Previously we could lose topic IDs in the
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
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
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
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
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=17350654#comment-17350654
]
Ryan Cabral commented on KAFKA-12838:
-
Yes, increasing the number of partitions can help reduce
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
[
https://issues.apache.org/jira/browse/KAFKA-9168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350650#comment-17350650
]
A. Sophie Blee-Goldman commented on KAFKA-9168:
---
Yep, all the rocksdb work waiting on more
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
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=17350606#comment-17350606
]
Ryanne Dolan commented on KAFKA-12838:
--
Would it help to significantly increase the number of
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
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
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
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
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=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:
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
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
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
--
[
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:
[
https://issues.apache.org/jira/browse/KAFKA-12629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350483#comment-17350483
]
John Roesler edited comment on KAFKA-12629 at 5/24/21, 3:22 PM:
Failed
[
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
[
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
[
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=17350483#comment-17350483
]
John Roesler commented on KAFKA-12629:
--
Failed also on:
John Roesler created KAFKA-12842:
Summary: Failing test:
org.apache.kafka.connect.integration.ConnectWorkerIntegrationTest.testSourceTaskNotBlockedOnShutdownWithNonExistentTopic
Key: KAFKA-12842
URL:
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
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
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
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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-12333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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
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
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
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
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
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
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
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:
[
https://issues.apache.org/jira/browse/KAFKA-12835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350330#comment-17350330
]
Ivan Yurchenko commented on KAFKA-12835:
bq. I was curious about your upgrade process. Is there
[
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
[
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=17350289#comment-17350289
]
Pham Huy Hoang commented on KAFKA-8120:
---
Hi [~wj1918], I tried to test as your above steps.
[
https://issues.apache.org/jira/browse/KAFKA-12805?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350279#comment-17350279
]
Luke Chen commented on KAFKA-12805:
---
[~nicolas.guyomar], I tried to set the
[
https://issues.apache.org/jira/browse/KAFKA-12773?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350274#comment-17350274
]
loboxu commented on KAFKA-12773:
[~jagsancio] Could you please tell me the name of your GitHub
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
[
https://issues.apache.org/jira/browse/KAFKA-12534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17350264#comment-17350264
]
kaushik srinivas commented on KAFKA-12534:
--
Hi [~cricket007]
To update more on this, the test
69 matches
Mail list logo
