[jira] [Created] (KAFKA-7153) Kafka commits transaction twice due to LeaveGroup

Kristian Kolding Foged-Ladefoged created KAFKA-7153: --- Summary: Kafka commits transaction twice due to LeaveGroup Key: KAFKA-7153 URL: https://issues.apache.org/jira/browse/KAFKA-7153

[jira] [Created] (KAFKA-7154) Apache kafka getting shut down everytime it is started

Pushkar Kumar created KAFKA-7154: Summary: Apache kafka getting shut down everytime it is started Key: KAFKA-7154 URL: https://issues.apache.org/jira/browse/KAFKA-7154 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-7155) the property CONFIG of the ProducerConfig maybe null.

zhangjk created KAFKA-7155: -- Summary: the property CONFIG of the ProducerConfig maybe null. Key: KAFKA-7155 URL: https://issues.apache.org/jira/browse/KAFKA-7155 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7156) Deleting topics with long names can bring all brokers to unrecoverable state

Petr Pchelko created KAFKA-7156: --- Summary: Deleting topics with long names can bring all brokers to unrecoverable state Key: KAFKA-7156 URL: https://issues.apache.org/jira/browse/KAFKA-7156 Project: Kaf

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

See Changes: [wangguoz] MINOR: Print exception stack traces in ConsumerGroupCommand. (#5286) -- [...truncated 552.94 KB...] kafka.zk.KafkaZkClientTest > testBrokerSequence

Re: [VOTE] 1.1.1 RC3

+1 (non-binding) Ran tests, Verified quick start, producer/consumer perf tests On Thu, Jul 12, 2018 at 11:06 AM Brett Rann wrote: > +1 (non binding) > rolling upgrade of shared staging multitenacy (200+ consumer groups) > cluster from 1.1.0 to 1.1.1-rc3 using the kafka_2.11-1.1.1.tgz artifa

[jira] [Created] (KAFKA-7157) Connect TimestampConverter SMT doesn't handle null values

Randall Hauch created KAFKA-7157: Summary: Connect TimestampConverter SMT doesn't handle null values Key: KAFKA-7157 URL: https://issues.apache.org/jira/browse/KAFKA-7157 Project: Kafka Issue

Re: [VOTE] 2.0.0 RC2

+1 non-binding Built from source, ran tests, ran quickstart and check signatures Thanks! On Wed, Jul 11, 2018 at 10:48 PM, Jakub Scholz wrote: > +1 (non-binbding) ... I built the RC2 from source, run tests and used it > with several of my applications without any problems. > > Thanks & Regards

KIP-327: Add describe all topics API to AdminClient

Hi all, I have created a KIP to add describe all topics API to AdminClient . https://cwiki.apache.org/confluence/display/KAFKA/KIP-327%3A+Add+describe+all+topics+API+to+AdminClient Please take a look. Thanks,

[jira] [Created] (KAFKA-7158) Duplicates when searching kafka stream state store with caching

Christian Henry created KAFKA-7158: -- Summary: Duplicates when searching kafka stream state store with caching Key: KAFKA-7158 URL: https://issues.apache.org/jira/browse/KAFKA-7158 Project: Kafka

Re: [DISCUSS] KIP-320: Allow fetchers to detect and handle log truncation

Hey Anna and Dong, Thanks a lot for the great discussion. I've been hanging back a bit because honestly the best option hasn't seemed clear. I agree with Anna's general observation that there is a distinction between the position of the consumer and its fetch state up to that position. If you thin

[jira] [Resolved] (KAFKA-6746) Allow ZK Znode configurable for Kafka broker

[ https://issues.apache.org/jira/browse/KAFKA-6746?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6746. -- Resolution: Fixed Fixed via https://github.com/apache/kafka/pull/5358 > Allow ZK Znode configurable fo

Re: [VOTE] 2.0.0 RC2

+1 1. Ran unit tests 2. Tested few use cases through 3-node cluster. Thanks, Harsha On Thu, Jul 12, 2018, at 9:33 AM, Mickael Maison wrote: > +1 non-binding > Built from source, ran tests, ran quickstart and check signatures > > Thanks! > > > On Wed, Jul 11, 2018 at 10:48 PM, Jakub Scholz wro

Re: KIP-327: Add describe all topics API to AdminClient

Very useful. LGTM. Thanks, Harsha On Thu, Jul 12, 2018, at 9:56 AM, Manikumar wrote: > Hi all, > > I have created a KIP to add describe all topics API to AdminClient . > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-327%3A+Add+describe+all+topics+API+to+AdminClient > > Please take a

Re: [VOTE] 1.1.1 RC3

+1. 1. Ran unit tests 2. Ran 3 node cluster to run few tests. Thanks, Harsha On Thu, Jul 12, 2018, at 7:29 AM, Manikumar wrote: > +1 (non-binding) Ran tests, Verified quick start, producer/consumer perf > tests > > > > On Thu, Jul 12, 2018 at 11:06 AM Brett Rann > wrote: > > > +1 (non bin

[jira] [Resolved] (KAFKA-6636) ReplicaFetcherThread should not die if hw < 0

[ https://issues.apache.org/jira/browse/KAFKA-6636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6636. - Resolution: Fixed This is no longer an issue after KAFKA-3978; Ensure high watermark is always positive.

[jira] [Resolved] (KAFKA-6618) Prevent two controllers from updating znodes concurrently

[ https://issues.apache.org/jira/browse/KAFKA-6618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6618. - Resolution: Duplicate Duplicate of https://issues.apache.org/jira/browse/KAFKA-6082 > Prevent two contro

[jira] [Resolved] (KAFKA-5812) Represent logDir with case class where absolute path is required

[ https://issues.apache.org/jira/browse/KAFKA-5812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-5812. - Resolution: Won't Do > Represent logDir with case class where absolute path is required > ---

[jira] [Resolved] (KAFKA-6617) Improve controller performance by batching reassignment znode write operation

[ https://issues.apache.org/jira/browse/KAFKA-6617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6617. - Resolution: Fixed > Improve controller performance by batching reassignment znode write operation > -

[jira] [Resolved] (KAFKA-3145) CPU Usage Spike to 100% when network connection is to error port

[ https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-3145. - Resolution: Cannot Reproduce > CPU Usage Spike to 100% when network connection is to error port > ---

[jira] [Resolved] (KAFKA-4820) ConsumerNetworkClient.send() should not require global lock

[ https://issues.apache.org/jira/browse/KAFKA-4820?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-4820. - Resolution: Fixed > ConsumerNetworkClient.send() should not require global lock > ---

[jira] [Resolved] (KAFKA-3089) VerifiableProducer should do a clean shutdown in stop_node()

[ https://issues.apache.org/jira/browse/KAFKA-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-3089. - Resolution: Fixed > VerifiableProducer should do a clean shutdown in stop_node() > --

[jira] [Resolved] (KAFKA-6488) Prevent log corruption in case of OOM

[ https://issues.apache.org/jira/browse/KAFKA-6488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin resolved KAFKA-6488. - Resolution: Won't Do > Prevent log corruption in case of OOM > - > >

Re: KIP-327: Add describe all topics API to AdminClient

Hey Manikumar, As Kafka begins to scale to larger and larger numbers of topics/partitions, I'm a little concerned about the scalability of APIs such as this. The API looks benign, but imagine you have have a few million partitions. We already expose similar APIs in the producer and consumer, so pr

Re: [DISCUSS] KIP-320: Allow fetchers to detect and handle log truncation

Hey Jason, It is a great summary. The solution sounds good. I might have minor comments regarding the method name. But we can discuss that minor points later after we reach consensus on the high level API. Thanks, Dong On Thu, Jul 12, 2018 at 11:41 AM, Jason Gustafson wrote: > Hey Anna and Do

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

See Changes: [jason] MINOR: Additional detail in description for zookeeper.connect (#5358) -- [...truncated 2.48 MB...] org.apache.kafka.streams.processor.internals.Proces

Re: [DISCUSS] KIP-291: Have separate queues for control requests and data requests

Hi Dong, I've updated the motivation section of the KIP by explaining the cases that would have user impacts. Please take a look at let me know your comments. Thanks, Lucas On Mon, Jul 9, 2018 at 5:53 PM, Lucas Wang wrote: > Hi Dong, > > The simulation of disk being slow is merely for me to ea

Re: [VOTE] KIP-291: Have separate queues for control requests and data requests

Hi Jun, About 3, thanks for the clarification. I like your proposal in that it avoids the delay for controller requests when the data request queue is empty. In comparison, the approach I described earlier is simpler to understand and implement. Between these two I actually like your suggested ap

Re: [DISCUSS] KIP-291: Have separate queues for control requests and data requests

Thanks for the update Lucas. I think the motivation section is intuitive. It will be good to learn more about the comments from other reviewers. On Thu, Jul 12, 2018 at 9:48 PM, Lucas Wang wrote: > Hi Dong, > > I've updated the motivation section of the KIP by explaining the cases that > would

[jira] [Created] (KAFKA-7159) mark configuration files in confluent-kafka RPM SPEC file

Robert created KAFKA-7159: - Summary: mark configuration files in confluent-kafka RPM SPEC file Key: KAFKA-7159 URL: https://issues.apache.org/jira/browse/KAFKA-7159 Project: Kafka Issue Type: Improve