[jira] [Created] (KAFKA-10583) Thread-safety of AdminClient is not documented

2020-10-07 Thread Adem Efe Gencer (Jira)
Adem Efe Gencer created KAFKA-10583: --- Summary: Thread-safety of AdminClient is not documented Key: KAFKA-10583 URL: https://issues.apache.org/jira/browse/KAFKA-10583 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9930) Prevent ReplicaFetcherThread from throwing UnknownTopicOrPartitionException upon topic creation and deletion.

2020-10-07 Thread Adem Efe Gencer (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adem Efe Gencer resolved KAFKA-9930. Resolution: Fixed > Prevent ReplicaFetcherThread from throw

Is AdminClient of Kafka thread-safe?

2020-10-07 Thread Efe Gencer
Hi All, Other than a Stack Overflow comment (see https://stackoverflow.com/a/61738065) by Colin Patrick McCabe (CC'd), there is no source that verifies the thread-safety of KafkaAdminClient. * In particular, JavaDocs of KafkaAdminClient class and Admin interface have no discussion on thread

Re: [DISCUSS] KIP-660: Pluggable ReplicaAssignor

2020-10-05 Thread Efe Gencer
Hi Mickael, Thanks for the KIP! A call to an external system, e.g. Cruise Control, in the implementation of the provided interface can indeed help with the initial assignment of partitions. I am curious why the proposed `ReplicaAssignor#assignReplicasToBrokers` receives a list of partition ids

[jira] [Created] (KAFKA-9930) Prevent ReplicaFetcherThread from throwing UnknownTopicOrPartitionException upon topic creation and deletion.

2020-04-28 Thread Adem Efe Gencer (Jira)
Adem Efe Gencer created KAFKA-9930: -- Summary: Prevent ReplicaFetcherThread from throwing UnknownTopicOrPartitionException upon topic creation and deletion. Key: KAFKA-9930 URL: https://issues.apache.org/jira

[jira] [Created] (KAFKA-9373) Improve shutdown performance via lazy accessing the offset and time indices.

2020-01-06 Thread Adem Efe Gencer (Jira)
Adem Efe Gencer created KAFKA-9373: -- Summary: Improve shutdown performance via lazy accessing the offset and time indices. Key: KAFKA-9373 URL: https://issues.apache.org/jira/browse/KAFKA-9373

Streams meetup@LinkedIn (Oct 23)

2018-10-01 Thread Efe Gencer
Hi Kafka users and developers, We are going to host our quarterly Stream Processing Meetup@LinkedIn on Oct 23. There will be talks about Cruise Control, Stream Analytics Manager, and Apache Samza. Please check the details below if you are interested: https://www.meetup.com/Stream-Processing-Meet

[jira] [Created] (KAFKA-6877) Remove completedFetch upon a failed parse if it contains no records.

2018-05-07 Thread Adem Efe Gencer (JIRA)
Adem Efe Gencer created KAFKA-6877: -- Summary: Remove completedFetch upon a failed parse if it contains no records. Key: KAFKA-6877 URL: https://issues.apache.org/jira/browse/KAFKA-6877 Project

[jira] [Created] (KAFKA-6157) Fix repeated words words in JavaDoc and comments.

2017-11-01 Thread Adem Efe Gencer (JIRA)
Adem Efe Gencer created KAFKA-6157: -- Summary: Fix repeated words words in JavaDoc and comments. Key: KAFKA-6157 URL: https://issues.apache.org/jira/browse/KAFKA-6157 Project: Kafka Issue

Re: [ANNOUNCE] New committer: Jiangjie (Becket) Qin

2016-11-03 Thread Efe Gencer
Congratulations, Becket! Best, Efe 2016-11-03 11:22 GMT-04:00 Neha Narkhede : > Congratulations, Becket! Well done. > > On Wed, Nov 2, 2016 at 1:34 PM Eno Thereska > wrote: > > > Congrats! > > Eno > > > > > On 1 Nov 2016, at 05:57, Harsha Chintalapani wrote: > > > > > > Congrats Becket! > > >