Re: [DISCUSS] Apache Kafka 2.8.0 release

Thanks for volunteering John! +1 Ismael On Wed, Jan 6, 2021, 9:29 PM John Roesler wrote: > Hello All, > > I'd like to volunteer to be the release manager for our next > feature release, 2.8.0. If there are no objections, I'll > send out the release plan soon. > > Thanks, > John Roesler > >

[DISCUSS] Apache Kafka 2.8.0 release

Hello All, I'd like to volunteer to be the release manager for our next feature release, 2.8.0. If there are no objections, I'll send out the release plan soon. Thanks, John Roesler

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #377

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #331

See

Re: How does a consumer know the given partition is removed?

Hi Boyuan, You can create a *ConsumerRebalanceListener* and do something you want when *onPartitionsRevoked. * Please check this java doc for more information: https://kafka.apache.org/27/javadoc/org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html Thanks. Luke On Thu, Jan 7, 2021 at

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen reopened KAFKA-8460: -- > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition > ---

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

See Changes: [github] MINOR: code cleanup for Kafka Streams task interface (#9801) [github] KAFKA-9274: Fix commit-TimeoutException handling for EOS (#9800) ---

[jira] [Created] (KAFKA-12155) Delay increasing the log start offset

Jose Armando Garcia Sancio created KAFKA-12155: -- Summary: Delay increasing the log start offset Key: KAFKA-12155 URL: https://issues.apache.org/jira/browse/KAFKA-12155 Project: Kafka

Re: Why many "Load Bug xxx" JIRA bug by Tim?

Hi Matthias, Thanks for your explanation. I understand now. Thank you. Luke On Thu, Jan 7, 2021 at 2:00 AM Matthias J. Sax wrote: > This was a spamming attack. > > The user was blocked and the corresponding tickets were deleted. (Cf. > https://issues.apache.org/jira/browse/INFRA-21268) > > The

[jira] [Created] (KAFKA-12154) API and implementation for snapshot loading

Jose Armando Garcia Sancio created KAFKA-12154: -- Summary: API and implementation for snapshot loading Key: KAFKA-12154 URL: https://issues.apache.org/jira/browse/KAFKA-12154 Project: Kafka

How does a consumer know the given partition is removed?

Hi team, I'm working on a long run application, which uses the Kafka Consumer API to poll messages from a given topic and partition. I'm assigning the topic and partition manually by using consumer.assign() API and polling messages by using consumer.poll(). One common scenario for my application

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

See Changes: [github] MINOR: Combine repeated top-level error test in AlterIsrManagerTest (#9649) [github] KAFKA-10778; Fence appends after write failure (#9676) [github] MINOR: improve KafkaStrea

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

See Changes: [github] MINOR: improve KafkaStreams replication factor documentation (#9829) [github] KAFKA-10671: improve the partition.assignment.strategy docs (#9788)

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

See Changes: [github] KAFKA-10778; Fence appends after write failure (#9676) [github] MINOR: improve KafkaStreams replication factor documentation (#9829) [github] KAFKA-10671: improve the partition

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

See Changes: [github] MINOR: Combine repeated top-level error test in AlterIsrManagerTest (#9649) [github] KAFKA-10778; Fence appends after write failure (#9676) -

[jira] [Created] (KAFKA-12153) follower can hit OffsetOutOfRangeException during truncation

Jun Rao created KAFKA-12153: --- Summary: follower can hit OffsetOutOfRangeException during truncation Key: KAFKA-12153 URL: https://issues.apache.org/jira/browse/KAFKA-12153 Project: Kafka Issue Typ

Re: [VOTE] KIP-687: Automatic Reloading of Security Store

Thanks Boyang, +1 non binding There’s a copy paste error in: public static final String SSL_TRUSTSTORE_LOCATION_REFRESH_INTERVAL_MS_CONFIG = "ssl.keystore.location.refresh.interval.ms"; -- Igor On Wed, Jan 6, 2021, at 8:26 PM, Boyang Chen wrote: > Hey folks, > > just bumping up this th

Re: [VOTE] KIP-687: Automatic Reloading of Security Store

+1 Thank Boyang On Wed, Jan 6, 2021 at 12:27 PM Boyang Chen wrote: > Hey folks, > > just bumping up this thread and see if you have further comments. > > On Wed, Dec 16, 2020 at 3:25 PM Boyang Chen > wrote: > > > Hey there, > > > > I would like to start the voting for KIP-687: > > https://cwiki

Re: [VOTE] KIP-687: Automatic Reloading of Security Store

Hey folks, just bumping up this thread and see if you have further comments. On Wed, Dec 16, 2020 at 3:25 PM Boyang Chen wrote: > Hey there, > > I would like to start the voting for KIP-687: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-687 > %3A+Automatic+Reloading+of+Security+Store

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

See Changes: [github] MINOR: Combine repeated top-level error test in AlterIsrManagerTest (#9649) -- [...truncated 3.48 MB...] org.apache.kafka.streams.Topol

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

Hello all, Thanks to all who participated in the discussion and vote. I'm closing the vote now and marking KIP-695 as accepted: * 4 binding +1 (Guozhang, Bill, Matthias, and myself) * 2 non-binding +1 (Bruno and Walker) The PRs will follow shortly. Thanks, -John On Fri, 2020-12-18 at 11:53 -08

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

See Changes: [Manikumar Reddy] MINOR: Update log statements in alterBrokerConfigs/alterTopicConfigs methods -- [...truncated 7.02 MB...] org.apache.kafka.st

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

See Changes: [Manikumar Reddy] MINOR: Update log statements in alterBrokerConfigs/alterTopicConfigs methods -- [...truncated 7.02 MB...] org.apache.kafka.s

[jira] [Resolved] (KAFKA-10778) Stronger log fencing after write failure

[ https://issues.apache.org/jira/browse/KAFKA-10778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10778. - Fix Version/s: 2.8.0 Assignee: Tom Bentley Resolution: Fixed > Stronger

Re: Why many "Load Bug xxx" JIRA bug by Tim?

This was a spamming attack. The user was blocked and the corresponding tickets were deleted. (Cf. https://issues.apache.org/jira/browse/INFRA-21268) The "problem" is, that anybody can create an Jira account and create tickets. It's in the spirit of open source and the ASF to not lock down Jira, t

Re: [DISCUSS] KIP-687: Automatic Reloading of Security Store

Thanks Boyang. Someone mentioned my email never showed up, but basically I suggested tying the refresh configuration more directly to the configurations it would affect. I'm happy with the updates. -Jason On Tue, Jan 5, 2021 at 8:34 PM Boyang Chen wrote: > Thanks Jason for the feedback. I separ

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

See Changes: [Manikumar Reddy] MINOR: Update log statements in alterBrokerConfigs/alterTopicConfigs methods -- [...truncated 3.48 MB...] org.apache.kafka.st

Re: [VOTE] KIP-700: Add Describe Cluster API

+1 (binding). Thank you for driving this, David. On Wed, Jan 6, 2021 at 5:54 AM David Jacot wrote: > > Hi all, > > I'd like to start the vote on KIP-700: Add Describe Cluster API. This KIP > is here: > https://cwiki.apache.org/confluence/x/jQ4mCg > > Please take a look and vote if you can. > > Be

[GitHub] [kafka-site] scott-confluent opened a new pull request #318: [MINOR] updating infobip logo on powered-by page

scott-confluent opened a new pull request #318: URL: https://github.com/apache/kafka-site/pull/318 We had a request come in to update their logo. This is an automated message from the Apache Git Service. To respond to the mes

[VOTE] KIP-700: Add Describe Cluster API

Hi all, I'd like to start the vote on KIP-700: Add Describe Cluster API. This KIP is here: https://cwiki.apache.org/confluence/x/jQ4mCg Please take a look and vote if you can. Best, David

[jira] [Created] (KAFKA-12152) Idempotent Producer does not reset the sequence number of partitions without in-flight batches

David Jacot created KAFKA-12152: --- Summary: Idempotent Producer does not reset the sequence number of partitions without in-flight batches Key: KAFKA-12152 URL: https://issues.apache.org/jira/browse/KAFKA-12152

Re: [DISCUSS] KIP-702: The control plane needs to force the validation of requests from the controller

Hi, Can we have some discussion about this KIP? thanks, Wenbing On 2021/01/05 12:19:11, wenbing shen wrote: > Hi, > > I'd like to start the discussion on KIP-702 to enforce validation of control > requests for the control plane.The client can define the "bootstrap-servers" > as the control p

[jira] [Created] (KAFKA-12151) Closing the TopologyTestDriver from kafka-streams-test-utils raises UnsupportedOperationException

Jan Teichmann created KAFKA-12151: - Summary: Closing the TopologyTestDriver from kafka-streams-test-utils raises UnsupportedOperationException Key: KAFKA-12151 URL: https://issues.apache.org/jira/browse/KAFKA-1215

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

See Changes: [github] MINOR: make sure all dir jobs are completed (#9728) -- [...truncated 3.51 MB...] org.apache.kafka.streams.test.MockProcessorContextSta

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

See Changes: [github] MINOR: make sure all dir jobs are completed (#9728) -- [...truncated 3.51 MB...] org.apache.kafka.streams.test.MockProcessorContextStat

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

See Changes: [github] MINOR: make sure all dir jobs are completed (#9728) -- [...truncated 3.48 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shou

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

See Changes: [github] MINOR: Add a few missing entity type tags (#9828) -- [...truncated 7.02 MB...] org.apache.kafka.streams.test.MockProcessorContextStateS

Re: Why many "Load Bug xxx" JIRA bug by Tim?

I had to register this as spam and block them. I couldn’t disable it from ASF JiRA. I’m also curious to know how/why such surge occurred. Regards, On Wed, 6 Jan 2021 at 03:45, Luke Chen wrote: > Hi, > I received a lot of JIRA notification emails today, and they are all > titled: "Load Bug xxx