[jira] [Created] (KAFKA-12164) ssue when kafka connect worker pod restart, during creation of nested partition directories in hdfs file system.

kaushik srinivas created KAFKA-12164: Summary: ssue when kafka connect worker pod restart, during creation of nested partition directories in hdfs file system. Key: KAFKA-12164 URL: https://issues.apache.org/j

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

See Changes: [github] KAFKA-9566: Improve DeserializationExceptionHandler JavaDocs (#9837) [github] MINOR: revise error message from TransactionalRequestResult#await (#9843) -

[jira] [Created] (KAFKA-12163) Controller should ensure zkVersion is monotonically increasing when sending UpdateMetadata requests.

Badai Aqrandista created KAFKA-12163: Summary: Controller should ensure zkVersion is monotonically increasing when sending UpdateMetadata requests. Key: KAFKA-12163 URL: https://issues.apache.org/jira/browse/K

[jira] [Created] (KAFKA-12162) Kafka broker continued to run after failing to create "/brokers/ids/X" znode.

Badai Aqrandista created KAFKA-12162: Summary: Kafka broker continued to run after failing to create "/brokers/ids/X" znode. Key: KAFKA-12162 URL: https://issues.apache.org/jira/browse/KAFKA-12162

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

See Changes: [github] KAFKA-9566: Improve DeserializationExceptionHandler JavaDocs (#9837) -- [...truncated 6.97 MB...] org.apache.kafka.streams.test.MockProc

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

Hi Bruno, Thanks for the update! Hi Boyuan, For listTopics() method, it'll *always* do a remote call, which will have performance impact for sure. For partitionsFor() method, it'll *check cache first*, if not found in cache, then do a remote call to retrieve the topic partition info. So, I think

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

See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #362

See

[jira] [Created] (KAFKA-12161) Raft observers should not require an id to fetch

Jason Gustafson created KAFKA-12161: --- Summary: Raft observers should not require an id to fetch Key: KAFKA-12161 URL: https://issues.apache.org/jira/browse/KAFKA-12161 Project: Kafka Issue

[jira] [Created] (KAFKA-12160) KafkaStreams configs are documented incorrectly

Matthias J. Sax created KAFKA-12160: --- Summary: KafkaStreams configs are documented incorrectly Key: KAFKA-12160 URL: https://issues.apache.org/jira/browse/KAFKA-12160 Project: Kafka Issue T

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

+1, Thank you! 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: [DISCUSS] Apache Kafka 2.8.0 release

+1, Thank you!!! On Wed, Jan 6, 2021 at 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 > -- Gwen Shapira Engineer

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

See Changes: [github] KAFKA-10779; Reassignment tool sets throttles incorrectly when overriding a reassignment (#9807) -- [...truncated 3.48 MB...] org.apac

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

Might be a good idea, but it's out of scope for us, but Infra would need to do this. Maybe leave a comment on INFRA-21268 or create a new INFRA ticket for it? -Matthias On 1/7/21 9:14 AM, Adam Bellemare wrote: > If we do look to enable Captchas, I think it would be important that we > avoid cor

Re: [DISCUSS] Apache Kafka 2.8.0 release

Thanks for volunteering John! It's a +1 from me as well. -Bill On Thu, Jan 7, 2021 at 1:01 AM Ismael Juma wrote: > 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

[jira] [Resolved] (KAFKA-10779) Reassignment tool sets throttles incorrectly when overriding a reassignment

[ https://issues.apache.org/jira/browse/KAFKA-10779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-10779. - Fix Version/s: 2.8.0 Resolution: Fixed > Reassignment tool sets throttles incorre

[jira] [Created] (KAFKA-12159) kafka-console-producer prompt should redisplay after an error output

Victoria Bialas created KAFKA-12159: --- Summary: kafka-console-producer prompt should redisplay after an error output Key: KAFKA-12159 URL: https://issues.apache.org/jira/browse/KAFKA-12159 Project: K

[jira] [Created] (KAFKA-12158) Consider better return type of RaftClient.scheduleAppend

Jason Gustafson created KAFKA-12158: --- Summary: Consider better return type of RaftClient.scheduleAppend Key: KAFKA-12158 URL: https://issues.apache.org/jira/browse/KAFKA-12158 Project: Kafka

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #69

See Changes: [Mickael Maison] Bump version to 2.6.1 [Mickael Maison] MINOR: Update 2.6 branch version to 2.6.2-SNAPSHOT -- [...truncated 3.17 MB...] org.apache

[GitHub] [kafka-site] bbejeck commented on a change in pull request #319: Updates for 2.6.1

bbejeck commented on a change in pull request #319: URL: https://github.com/apache/kafka-site/pull/319#discussion_r553560365 ## File path: 26/documentation.html ## @@ -41,7 +41,7 @@ 1.2 Use Cases 1.3 Quick Start - + Review comment: Also, you'l

[jira] [Resolved] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-10633. - Resolution: Fixed > Constant probing rebalances in Streams 2.6 > ---

[jira] [Reopened] (KAFKA-10633) Constant probing rebalances in Streams 2.6

[ https://issues.apache.org/jira/browse/KAFKA-10633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-10633: - > Constant probing rebalances in Streams 2.6 > -- >

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

See Changes: [Manikumar Reddy] MINOR: Add a log to print acl change notification details -- [...truncated 7.02 MB...] org.apache.kafka.streams.test.MockProc

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

Hey David, thanks for the feedback. On Thu, Jan 7, 2021 at 2:37 AM David Jacot wrote: > Hi Boyang, > > Thanks for the KIP. I am fine with it in general. I just have a few > comments. > > With the proposal, we don't have the guarantee that both the new keystore > and the new truststore will be pi

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

Thanks, folks! It seems like partitionsFor() and listTopics() is what I want. Do we have performance estimates on these 2 API calls, e.g., the time cost of waiting for responses? I would invoke these API along a hot path so I want to have a general idea on how bad it could be. Many thanks to your

[GitHub] [kafka-site] mimaison opened a new pull request #319: Updates for 2.6.1

mimaison opened a new pull request #319: URL: https://github.com/apache/kafka-site/pull/319 - Copied docs from 2.6.1 artifacts - Updated downloads.html to include 2.6.1 This is an automated message from the Apache Git Serv

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

Thanks Rajini for the comments. On Thu, Jan 7, 2021 at 2:27 AM Rajini Sivaram wrote: > Hi Boyang, > > Thanks for the KIP, I have a few questions: > > 1) Will it be possible to enable/disable automatic file reloading? If not, > we should mention in the compatibility section. > I don't think we ne

Build failed in Jenkins: Kafka » kafka-2.5-jdk8 #29

See Changes: [Manikumar Reddy] MINOR: Add a log to print acl change notification details -- [...truncated 3.10 MB...] org.apache.kafka.streams.test.OutputVerifi

Re: [RESULTS] [VOTE] Release Kafka version 2.6.1

Hi Gary, Yes I expect it to be ready in the next couple of days. Thanks On Thu, Jan 7, 2021 at 5:07 PM Gary Russell wrote: > > Thanks; it would be greatly appreciated if this can happen before Jan 14 at > the latest. > > From: Mickael Maison > Sent: Thursday,

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

See Changes: [Manikumar Reddy] MINOR: Add a log to print acl change notification details -- [...truncated 3.48 MB...] org.apache.kafka.streams.TopologyTestDri

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

See Changes: [Manikumar Reddy] MINOR: Add a log to print acl change notification details -- [...truncated 3.51 MB...] org.apache.kafka.streams.test.MockProc

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

If we do look to enable Captchas, I think it would be important that we avoid corporate offerings (eg: Google's). On Thu, Jan 7, 2021 at 12:12 PM Govinda Sakhare wrote: > Hi, > > If it is possible, we should configure/enable Captcha to prevent automated > spamming attacks. > > Thanks > Govinda

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

Hi, If it is possible, we should configure/enable Captcha to prevent automated spamming attacks. Thanks Govinda On Wed, Jan 6, 2021 at 11:30 PM Matthias J. Sax wrote: > This was a spamming attack. > > The user was blocked and the corresponding tickets were deleted. (Cf. > https://issues.apache

Re: [RESULTS] [VOTE] Release Kafka version 2.6.1

Thanks; it would be greatly appreciated if this can happen before Jan 14 at the latest. From: Mickael Maison Sent: Thursday, January 7, 2021 11:29 AM To: dev ; Users ; kafka-clients Subject: [RESULTS] [VOTE] Release Kafka version 2.6.1 This vote passes with 3 +

[RESULTS] [VOTE] Release Kafka version 2.6.1

This vote passes with 3 +1 votes (3 bindings) and no 0 or -1 votes. +1 votes PMC Members: * Rajini Sivaram * Manikumar Reddy * Matthias J. Sax Committers: * No votes Community: * No votes 0 votes * No votes -1 votes * No votes Vote thread: https://lists.apache.org/thread.html/r18b6939b16652cd

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #87

See Changes: [Manikumar Reddy] MINOR: Add a log to print acl change notification details -- [...truncated 3.44 MB...] org.apache.kafka.streams.test.OutputVerifi

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

See Changes: [github] KAFKA-10874: Fix flaky ClientQuotasRequestTest.testAlterIpQuotasRequest (#9778) -- [...truncated 3.48 MB...] org.apache.kafka.streams.

Re: [kafka-clients] Re: [VOTE] 2.6.1 RC3

Hi Ismael, As far as I can tell, Kafka is not using the jackson-databind API that had the issue. If this is fine, I'll mark this vote as passed and I'll continue the release process. Thanks On Tue, Jan 5, 2021 at 4:27 PM Ismael Juma wrote: > > Hi Mickael, > > Does that CVE even affect Kafka? Not

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

+1 > 6 янв. 2021 г., в 16:53, David Jacot написал(а): > > 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

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

Hi Boyang, Thanks for the KIP. I am fine with it in general. I just have a few comments. With the proposal, we don't have the guarantee that both the new keystore and the new truststore will be picked up together so we may end up with the new keystore and the old truststore for a short period of

Re: [jira] [Created] (KAFKA-12157) test Upgrade 2.7.0 from 2.0.0 occur a question

Hi,team I ran into a problem while testing the 2.0.0 rolling upgrade 2.7.0. I tried to reproduce it again and it failed. I am curious how this problem is caused, can anyone help analyze it? Thanks. Wenbing Wenbing Shen (Jira) 于2021年1月7日周四 下午6:26写道： > Wenbing Shen created KAFKA-12157: > -

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

Hi Boyang, Thanks for the KIP, I have a few questions: 1) Will it be possible to enable/disable automatic file reloading? If not, we should mention in the compatibility section. 2) We are introducing new common SSL configs and updating common code to perform automated updates. What does this mea

[jira] [Created] (KAFKA-12157) test Upgrade 2.7.0 from 2.0.0 occur a question

Wenbing Shen created KAFKA-12157: Summary: test Upgrade 2.7.0 from 2.0.0 occur a question Key: KAFKA-12157 URL: https://issues.apache.org/jira/browse/KAFKA-12157 Project: Kafka Issue Type: Bu

[jira] [Created] (KAFKA-12156) Document consequences of single threaded response handling

Tom Bentley created KAFKA-12156: --- Summary: Document consequences of single threaded response handling Key: KAFKA-12156 URL: https://issues.apache.org/jira/browse/KAFKA-12156 Project: Kafka Issu

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

Hi Luke, I am afraid the ConsumerRebalanceListener will not work in this case since Boyuan assigns the partitions manually. The Java docs you linked state If the consumer directly assigns partitions, those partitions will never be reassigned and this callback is not applicable. Hi Boyuan,

[jira] [Resolved] (KAFKA-10874) Fix flaky ClientQuotasRequestTest.testAlterIpQuotasRequest

[ https://issues.apache.org/jira/browse/KAFKA-10874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-10874. - Fix Version/s: 2.8.0 Resolution: Fixed > Fix flaky ClientQuotasRequestTest.testAlterIpQuo