[jira] [Created] (KAFKA-7451) Missing JMX metrics

Jork Zijlstra created KAFKA-7451: Summary: Missing JMX metrics Key: KAFKA-7451 URL: https://issues.apache.org/jira/browse/KAFKA-7451 Project: Kafka Issue Type: Bug Components: consu

[jira] [Created] (KAFKA-7450) kafka controller RequestSendThread stuck in infinite loop after SSL handshake failure with peer brokers

Yu Yang created KAFKA-7450: -- Summary: kafka controller RequestSendThread stuck in infinite loop after SSL handshake failure with peer brokers Key: KAFKA-7450 URL: https://issues.apache.org/jira/browse/KAFKA-7450

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-eu2 (ubuntu trusty) in workspace

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H31 (ubuntu xenial) in workspace

[jira] [Resolved] (KAFKA-7409) Validate topic configs prior to topic creation

[ https://issues.apache.org/jira/browse/KAFKA-7409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7409. Resolution: Fixed Fix Version/s: 2.1.0 > Validate topic configs prior to topic creat

Re: [DISCUSSION] KIP-376: Implement AutoClosable on appropriate classes that has close()

> (Although I am not quite sure > when one is more desirable than the other) Most kafka's classes implementing Closeable/AutoCloseable doesn't throw checked exception in close() method. Perhaps we should have a "KafkaCloseable" interface which has a close() method without throwing any checked ex

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

I agree with you Rhys that Kafka Connect is an integral part of Apache Kafka and it perfectly makes sense, in many cases, not to overload the core or the clients with responsibilities that are related to data export to and data import from specific systems. That can be true even when Kafka itself i

Re: [VOTE] KIP-354 Time-based log compaction policy

Thanks Eno, Brett, Dong, Guozhang, Colin, and Xiaohe for feedback. Can I have more feedback or VOTE on this KIP? Xiongqi (Wesley) Wu On Wed, Sep 19, 2018 at 10:52 AM xiongqi wu wrote: > Any other votes or comments? > > Xiongqi (Wesley) Wu > > > On Tue, Sep 11, 2018 at 11:45 AM xiongqi wu wr

Build failed in Jenkins: kafka-1.1-jdk7 #204

See Changes: [jason] KAFKA-7414; Out of range errors should never be fatal for follower -- [...truncated 425.29 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldCl

Re: [DISCUSSION] KIP-376: Implement AutoClosable on appropriate classes that has close()

Hi All, Chia-Ping, I agree, similar to VarifiableConsumer, VarifiableProducer should be implementing Closeable as well (Although I am not quite sure when one is more desirable than the other), also I just looked through your list - these are some great additions, I will add them to the list. Than

wiki permission please!

I would like to create some KIPs. JIRA user: ryannedolan wiki user: ryannedolan Ryanne Dolan ryannedo...@gmail.com Thanks! Ryanne

Re: [ANNOUNCE] New committer: Colin McCabe

Congratulations Colin! Keep up the good work! On Wed, Sep 26, 2018 at 7:27 PM Yishun Guan wrote: > Congrats! -Yishun > > On Wed, Sep 26, 2018, 10:04 AM Konstantine Karantasis < > konstant...@confluent.io> wrote: > > > Well deserved! Congratulations Colin. > > > > -Konstantine > > > > On Wed, Sep

[jira] [Created] (KAFKA-7449) Kafka console consumer is not sending topic to deserializer

Mathieu Chataigner created KAFKA-7449: - Summary: Kafka console consumer is not sending topic to deserializer Key: KAFKA-7449 URL: https://issues.apache.org/jira/browse/KAFKA-7449 Project: Kafka

[jira] [Created] (KAFKA-7448) KAFKA-network Disconnect issue while invoking in acamel-Websphere

Nandhini created KAFKA-7448: --- Summary: KAFKA-network Disconnect issue while invoking in acamel-Websphere Key: KAFKA-7448 URL: https://issues.apache.org/jira/browse/KAFKA-7448 Project: Kafka Issue

[jira] [Created] (KAFKA-7447) Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown

Ben Isaacs created KAFKA-7447: - Summary: Consumer offsets lost during leadership rebalance after bringing node back from clean shutdown Key: KAFKA-7447 URL: https://issues.apache.org/jira/browse/KAFKA-7447

Re: [DISCUSS] KIP-375: TopicCommand to use AdminClient

No problem. Thanks! - Dongjin On Thu, Sep 27, 2018 at 7:28 PM Viktor Somogyi-Vass wrote: > Hi All, > > A technical update: around the time I created this KIP, another one got > created with the same number and therefore to avoid collisions in KIP > numbers I chose to increment my KIP's number,

Re: [DISCUSS] KIP-375 Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable

Hi Pavel, I have changed my KIP's number to 377 so all sorted out. Cheers, Viktor On Wed, Sep 26, 2018 at 4:53 PM Viktor Somogyi-Vass wrote: > Hi Pavel, > > May I kindly ask you to increment your KIP number? :) > As it turns out I have already created one with this number a little bit > earlie

[DISCUSS] KIP-377: TopicCommand to use AdminClient

Hi All, This is the continuation of the old KIP-375 with the same title: https://lists.apache.org/thread.html/dc71d08de8cd2f082765be22c9f88bc9f8b39bb8e0929a3a4394e9da@%3Cdev.kafka.apache.org%3E The problem there was that two KIPs were created around the same time and I chose to reorganize mine a

Re: [DISCUSS] KIP-375: TopicCommand to use AdminClient

Hi All, A technical update: around the time I created this KIP, another one got created with the same number and therefore to avoid collisions in KIP numbers I chose to increment my KIP's number, so the new URL where it is available is: https://cwiki.apache.org/confluence/display/KAFKA/KIP-377%3A+

Re: [DISCUSSION] KIP-376: Implement AutoClosable on appropriate classes that has close()

Hi Yishun, Thank you for your great KIP. In fact, I have also encountered the cases where Autoclosable is so desired several times! Let me inspect more candidate classes as well. +1. I also refined your KIP a little bit. Best, Dongjin On Thu, Sep 27, 2018 at 12:21 PM Chia-Ping Tsai wrote: > h

[jira] [Created] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow

Jacek Laskowski created KAFKA-7446: -- Summary: Better error message to explain the upper limit of TimeWindow Key: KAFKA-7446 URL: https://issues.apache.org/jira/browse/KAFKA-7446 Project: Kafka

[jira] [Created] (KAFKA-7445) Branch one Stream in multiple Streams

Dennis Reiter created KAFKA-7445: Summary: Branch one Stream in multiple Streams Key: KAFKA-7445 URL: https://issues.apache.org/jira/browse/KAFKA-7445 Project: Kafka Issue Type: New Feature