Jenkins build is back to normal : Kafka » kafka-2.7-jdk8 #118

See

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #7

See Changes: [github] MINOR: Prevent creating partition.metadata until ID can be written (#10100) -- [...truncated 3.37 MB...] LogManagerTest >

[jira] [Resolved] (KAFKA-12182) Kafka connector is failing due to ' OffsetStorageWriter is already flushing' error

[ https://issues.apache.org/jira/browse/KAFKA-12182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-12182. --- Resolution: Duplicate > Kafka connector is failing due to ' OffsetStorageWriter is already

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #6

See Changes: [Colin McCabe] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord (#10101) [Colin McCabe] MINOR: Add RaftReplicaManager (#10069) --

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #504

See Changes: [github] MINOR: Prevent creating partition.metadata until ID can be written (#10041) -- [...truncated 3.45 MB...] SocketServerTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #527

See Changes: [github] MINOR: Prevent creating partition.metadata until ID can be written (#10041) -- [...truncated 3.62 MB...] AclAuthorizerTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #473

See Changes: [github] MINOR: Prevent creating partition.metadata until ID can be written (#10041) -- [...truncated 3.58 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #503

See Changes: [github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord (#10101) [github] MINOR: Add RaftReplicaManager (#10069) --

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #526

See Changes: [github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord (#10101) [github] MINOR: Add RaftReplicaManager (#10069) --

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #472

See Changes: [github] MINOR: Add ClientQuotaMetadataManager for processing QuotaRecord (#10101) [github] MINOR: Add RaftReplicaManager (#10069) --

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #5

See Changes: [Colin McCabe] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084) [Colin McCabe] JUnit extensions for integration tests (#9986) --

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #471

See Changes: [github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084) -- [...truncated 3.49 MB...] LogValidatorTest > testNonCompressedV1()

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #502

See Changes: [github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084) -- [...truncated 3.49 MB...] KafkaZkClientTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #525

See Changes: [github] MINOR: Rename DecommissionBrokers to UnregisterBrokers (#10084) -- [...truncated 3.63 MB...] AuthorizerIntegrationTest >

Re: [DISCUSS] KIP-712: Shallow Mirroring

On the question "whether shallow mirror is only applied on mirror maker v1", the code change is mostly on consumer and producer code path, the change to mirrormaker v1 is very trivial. We chose to modify the consumer/producer path (instead of creating a new mirror product) so other use cases can

Re: [DISCUSS] KIP-712: Shallow Mirroring

Retitled the thread to conform to the common format. On Fri, Feb 5, 2021 at 4:00 PM Ning Zhang wrote: > Hello Henry, > > This is a very interesting proposal. > https://issues.apache.org/jira/browse/KAFKA-10728 reflects the similar > concern of re-compressing data in mirror maker. > > Probably

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

Hey John, I know I'm a bit late to this party but just for the record, I don't think it's *totally *unreasonable for a user to take up the "poll on max timeout and assume some records will be returned" approach. And I also can imagine plenty of manually-assigned consumers implemented doing exactly

[jira] [Resolved] (KAFKA-12322) Why https://downloads.apache.org/kafka/ it doesnot download older version only 2.7.0 and 2.6.1 ,is there any changes done ?

[ https://issues.apache.org/jira/browse/KAFKA-12322?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-12322. - Resolution: Not A Problem > Why https://downloads.apache.org/kafka/ it doesnot

Re: [DISCUSS] Apache Kafka 2.6.2 release

Ok, thanks for the update! On Wed, Feb 10, 2021 at 1:06 AM Luke Chen wrote: > Hi Ismael & Sophie, > Sorry, after some investigation, I think this might not be a defect. To > work with the project with a specific scala version, user might need to use > the same version as the project used. This

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #524

See Changes: [github] MINOR: KafkaBroker.brokerState should be volatile instead of AtomicReference (#10080) -- [...truncated 7.23 MB...]

Re: [VOTE] KIP-695: Improve Streams Time Synchronization

Hello again, all. I have submitted the PR: https://github.com/apache/kafka/pull/10096 Ismael chimed in on the PR review to indicate that the config approach may not be desirable. How strongly do we feel that the behavior change is unacceptable? It seems like most of the people involved felt the

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #501

See Changes: [github] MINOR: KafkaBroker.brokerState should be volatile instead of AtomicReference (#10080) -- [...truncated 3.60 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #470

See Changes: [github] MINOR: KafkaBroker.brokerState should be volatile instead of AtomicReference (#10080) -- [...truncated 3.58 MB...] SocketServerTest >

Jenkins build is back to normal : Kafka » kafka-2.5-jdk8 #39

See

Re: Apply for KIP permission

You're all set now. Thanks for your interest in Apache Kafka! -Bill On Wed, Feb 10, 2021 at 10:48 AM Nirvana <1572139...@qq.com> wrote: > Apply for KIP permission, My account name is1572139390！ > Thrank you !

Apply for KIP permission

Apply for KIP permission, My account name is1572139390?? Thrank you !

Apply for KIP permission

Apply for KIP permission, My account name is 1572139390?? Thrank you ! I submitted a patch , https://github.com/apache/kafka/pull/9870

[jira] [Created] (KAFKA-12322) Why https://downloads.apache.org/kafka/ it doesnot download older version only 2.7.0 and 2.6.1 ,is there any changes done ?

suman tripathi created KAFKA-12322: -- Summary: Why https://downloads.apache.org/kafka/ it doesnot download older version only 2.7.0 and 2.6.1 ,is there any changes done ? Key: KAFKA-12322 URL:

[jira] [Created] (KAFKA-12321) the comparison function for uuid type should be 'equals' rather than '=='

Chia-Ping Tsai created KAFKA-12321: -- Summary: the comparison function for uuid type should be 'equals' rather than '==' Key: KAFKA-12321 URL: https://issues.apache.org/jira/browse/KAFKA-12321

Jenkins build is back to normal : Kafka » kafka-2.3-jdk8 #17

See

[jira] [Created] (KAFKA-12320) Provide JSON vulnerability data

Shivam Sandbhor created KAFKA-12320: --- Summary: Provide JSON vulnerability data Key: KAFKA-12320 URL: https://issues.apache.org/jira/browse/KAFKA-12320 Project: Kafka Issue Type:

Build failed in Jenkins: Kafka » kafka-2.8-jdk8 #4

See Changes: [Rajini Sivaram] Fill in the 2.8 release note for Authorizer (#9865) -- [...truncated 3.59 MB...] AclAuthorizerTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #523

See Changes: [github] Fill in the 2.8 release note for Authorizer (#9865) -- [...truncated 3.61 MB...] AclAuthorizerTest > testTopicAcl() STARTED

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #469

See Changes: [github] Fill in the 2.8 release note for Authorizer (#9865) -- [...truncated 3.60 MB...] TransactionsTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #500

See Changes: [github] Fill in the 2.8 release note for Authorizer (#9865) -- [...truncated 3.60 MB...] ControllerEventManagerTest >

Re: [DISCUSS] Apache Kafka 2.6.2 release

Hi Ismael & Sophie, Sorry, after some investigation, I think this might not be a defect. To work with the project with a specific scala version, user might need to use the same version as the project used. This issue also happened on other projects using scala, ex: Spark. ref: