RE: [EXTERNAL] Re: Request for access to create KIP

Accountid: koushikchitta Cheers, Koushik -Original Message- From: Boyang Chen Sent: Sunday, August 9, 2020 6:02 PM To: dev Subject: [EXTERNAL] Re: Request for access to create KIP Have you created the account already? What's your account id? On Sat, Aug 8, 2020 at 4:36 PM Koushik

Request for access to create KIP

Hi Team, Can you please grant me access to create KIP ? Thanks, Koushik

RE: Issue in retention with compact,delete cleanup policy

Bubbling this up to understand if anyone else are in similar use case. -Original Message- From: Koushik Chitta Sent: Sunday, February 23, 2020 1:35 PM To: us...@kafka.apache.org; dev@kafka.apache.org Subject: [EXTERNAL] Issue in retention with compact,delete cleanup policy Hi, I have

Issue in retention with compact,delete cleanup policy

Hi, I have a Topic with following config. cleanup.policy = compact,delete segment.bytes = 52428800 (~52 mb) min.compaction.lag.ms = 180 (30 min) delete.retention.ms = 8640 (1 day) retention.ms = 25920 (3 days) Ideally I would want the old records > 3 days to be deleted without

RE: [VOTE] KIP-455: Create an Administrative API for Replica Reassignment

what's wrong with replication is a pretty tough > > problem. If we had an API for this, we'd probably want it to be unified, > > and not specific to reassigning partitions. > > > > regards, > > Colin > > > > > > On Tue, Aug 6, 2019, at 10:5

RE: [VOTE] KIP-455: Create an Administrative API for Replica Reassignment

Hey Colin, Can the ListPartitionReassignmentsResult include the status of the current reassignment progress of each partition? A reassignment can be in progress for different reasons and the status can give the option to alter the current reassignment. Example - A leaderISRRequest of a new

Use of version attribute in reassignment json of kafka-reassign-partitions.sh

Hi, What is the use/intention of version attribute in kafka-reassign-partitions.sh command ? I see the code(at least version 1.1) just ignores this attribute. > bin/kafka-reassign-partitions.sh --zookeeper localhost:2181 > --reassignment-json-file expand-cluster-reassignment.json --execute

Inconsistent Replica list for a partition

Hi, The no. of replicas of partition : 1 is less than rest of the partitions, In which scenarios this can happen ? Kafka version - 0.10.2 [cid:image001.png@01D4616F.405D2FA0] Thanks, Koushik

RE: Kafka consumer to unzip stream of .gz files and read

You should read the message value as byte array rather than string . Other Approach is , while producing you can use the kafka compression = GZIP to have similar results. -Original Message- From: mayur shah Sent: Monday, May 21, 2018 1:50 AM To:

SSL Keymanager implementation using OS managed keystore

Hi, Running kafka on Windows OS, I would like to take advantage of windows managed keystore (eg: Windows-MY, can be loaded without a user, pass) .Eventually wants to use a custom keymanager implementation. >From the code I see, SSLFactory doesn't allow to use an existing keystore and >without

RE: [VOTE] KIP-257 - Configurable Quota Management

+1 . Thanks for the KIP. -Original Message- From: Rajini Sivaram Sent: Thursday, March 22, 2018 2:57 PM To: dev Subject: [VOTE] KIP-257 - Configurable Quota Management Hi all, I would like to start vote on KIP-257 to enable customisation