[jira] [Resolved] (KAFKA-6701) synchronize Log modification between delete cleanup and async delete

[ https://issues.apache.org/jira/browse/KAFKA-6701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6701. - Resolution: Fixed The issue appears to have been fixed in https://issues.apache.org/jira/browse/KAFKA-51

Re: [DISCUSS] KIP-346 - Limit blast radius of log compaction failure

Hey Jason, My initial suggestion was to *track *the uncleanable disk space. I can see why marking a log directory as offline after a certain threshold of uncleanable disk space is more useful. I'm not sure if we can set that threshold to be of certain size (e.g 100GB) as log directories might have

Re: [EXTERNAL] [VOTE] KIP-310: Add a Kafka Source Connector to Kafka Connect

Hi Rhys, Overall I'm +1 (non binding), but you're going to need 3 binding votes for this KIP to pass. I don't feel there has been enough discussion on this from the community. Can we get some input from other people? Thanks for starting the vote nonetheless :) Stephane On 8 August 2018 at 20:28,

Re: [DISCUSS] KIP-342 Add Customizable SASL extensions to OAuthBearer authentication

Hi Rajini, Ron I've updated the KIP with the latest changes following our discussion. Please do give it a read. If you feel it is alright, I will follow up with a PR later. Best, Stanislav On Thu, Aug 9, 2018 at 10:09 AM Rajini Sivaram wrote: > Hi Ron/Stansilav, > > OK, let's just go with 2. I

Re: [DISCUSS] KIP-317: Transparent Data Encryption

Hi Viktor, thanks for your input! We could accommodate magic headers by removing any known fixed bytes pre-encryption, sticking them in a header field and prepending them after decryption. However, I am not sure whether this is actually necessary, as most modern (AES for sure) algorithms are consi

Re: [DISCUSS] KIP-342 Add Customizable SASL extensions to OAuthBearer authentication

Hi Stanislav. Here are a few KIP comments. <

[jira] [Created] (KAFKA-7275) Prototype lock-free metrics

John Roesler created KAFKA-7275: --- Summary: Prototype lock-free metrics Key: KAFKA-7275 URL: https://issues.apache.org/jira/browse/KAFKA-7275 Project: Kafka Issue Type: Improvement Com

[jira] [Created] (KAFKA-7276) Consider using re2j to speed up regex operations

Ted Yu created KAFKA-7276: - Summary: Consider using re2j to speed up regex operations Key: KAFKA-7276 URL: https://issues.apache.org/jira/browse/KAFKA-7276 Project: Kafka Issue Type: Task

Re: [DISCUSS] KIP-342 Add Customizable SASL extensions to OAuthBearer authentication

Hi Stanislav, For the point that Ron made above for: public OAuthBearerExtensionsValidatorCallback(OAuthBearerToken token, SaslExtensions extensions) I don't think we should ever invoke extensions callback without the token. We can first validate the token and invoke extensions callback only if

Re: [DISCUSS] KIP-347: Enable batching in FindCoordinatorRequest

It would be great if I could get some feedbacks on this KIP, thanks! On Thu, Aug 9, 2018, 10:35 AM Yishun Guan wrote: > To add more context for KIP-347: https://github.com/apache/kafka/pull/5353 > > On Wed, Aug 8, 2018 at 3:55 PM Yishun Guan wrote: > >> Hi all, >> >> I would like to start a dis

Re: [EXTERNAL] [VOTE] KIP-310: Add a Kafka Source Connector to Kafka Connect

Thanks Stephane! If there is a desire for further discussion I am certainly open to reverting this to a discussion thread. For now I’ll keep this vote open until we get either 3 binding votes or further request for discussion from the community. Do you have any additional thoughts on the KIP yo

Re: [VOTE] KIP-280: Enhanced log compaction

Hi Luis, It's still not very clear to me why we need the header-based strategy. Can you elaborate why having the timestamp-based approach alone is not sufficient? The use case in the motivation just describes a "most recent snapshot" use case. Thanks, Jason On Thu, Aug 9, 2018 at 4:36 AM, Luís C

[jira] [Created] (KAFKA-7277) Migrate Streams API to Duration instead of longMs times

John Roesler created KAFKA-7277: --- Summary: Migrate Streams API to Duration instead of longMs times Key: KAFKA-7277 URL: https://issues.apache.org/jira/browse/KAFKA-7277 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-7147) Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file

[ https://issues.apache.org/jira/browse/KAFKA-7147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-7147. - Resolution: Fixed > Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client > prop

Re: [DISCUSS] KIP-347: Enable batching in FindCoordinatorRequest

bq. this is the foundation of some later possible optimizations(enable batching in *describeConsumerGroups ...* *Can you say more why this change lays the foundation for the future optimizations ?* *You mentioned **FIND_COORDINATOR_REQUEST_V3 in the wiki but I don't see it in PR.* *I assume you w

[jira] [Resolved] (KAFKA-6966) Extend `TopologyDescription.Sink` to return `TopicNameExtractor`

[ https://issues.apache.org/jira/browse/KAFKA-6966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6966. Resolution: Fixed > Extend `TopologyDescription.Sink` to return `TopicNameExtractor` >

Build failed in Jenkins: kafka-trunk-jdk10 #392

See Changes: [lindong28] KAFKA-7147; ReassignPartitionsCommand should be able to connect to -- [...truncated 1.54 MB...] kafka.zk.KafkaZkClientTest > testCreateAndGetTopi

Build failed in Jenkins: kafka-trunk-jdk8 #2884

See Changes: [lindong28] KAFKA-7147; ReassignPartitionsCommand should be able to connect to -- [...truncated 877.49 KB...] kafka.zookeeper.ZooKeeperClientTest > testConne

Jenkins build is back to normal : kafka-trunk-jdk10 #393

See

Build failed in Jenkins: kafka-trunk-jdk8 #2885

See Changes: [mjsax] KAFKA-6966: Extend TopologyDescription to better represent Source and -- [...truncated 428.43 KB...] kafka.zookeeper.ZooKeeperClientTest > testGetData

[jira] [Resolved] (KAFKA-7140) Remove deprecated poll usages

[ https://issues.apache.org/jira/browse/KAFKA-7140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7140. Resolution: Fixed > Remove deprecated poll usages > - > >