[jira] [Created] (KAFKA-6653) Delayed operations may not be completed when there is lock contention

Rajini Sivaram created KAFKA-6653: - Summary: Delayed operations may not be completed when there is lock contention Key: KAFKA-6653 URL: https://issues.apache.org/jira/browse/KAFKA-6653 Project: Kafka

Add me to contributor list

Hi, Would it be possible to add me to the contributor list? My jira username: JiminHsieh Thanks, Jimin Hsieh

Re: [VOTE] 1.1.0 RC2

Thanks for pointing out Satish. Links updated: Hello Kafka users, developers and client-developers, This is the third candidate for release of Apache Kafka 1.1.0. This is minor version release of Apache Kakfa. It Includes 29 new KIPs. Please see the

[jira] [Created] (KAFKA-6654) Customize SSLContext creation

Robert Wruck created KAFKA-6654: --- Summary: Customize SSLContext creation Key: KAFKA-6654 URL: https://issues.apache.org/jira/browse/KAFKA-6654 Project: Kafka Issue Type: Improvement C

Build failed in Jenkins: kafka-1.0-jdk7 #168

See Changes: [jason] MINOR: Remove kafka-consumer-offset-checker.bat for KAFKA-3356 (#4703) [jason] KAFKA-3978; Ensure high watermark is always positive (#4695) -- [...trunc

Zookeeper dependency

I saw a comment in https://issues.apache.org/jira/browse/KAFKA-6598 about the possibility of removing Kafka's dependency on Zookeeper. While I'm sure the promised KIP will have a lot of the interesting technical details, I was wondering if anyone was able to shed any light on this in terms of what

[jira] [Created] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

Srini created KAFKA-6655: Summary: CleanupThread] Failed to lock the state directory due to an unexpected exception Key: KAFKA-6655 URL: https://issues.apache.org/jira/browse/KAFKA-6655 Project: Kafka

Re: [VOTE] 1.1.0 RC2

+1 Ran test suite - passed (apart from testMetricsLeak which is flaky). On Wed, Mar 14, 2018 at 3:30 AM, Damian Guy wrote: > Thanks for pointing out Satish. Links updated: > > > > Hello Kafka users, developers and client-developers, > > This is the t

[jira] [Created] (KAFKA-6656) Use non-zero status code when kafka-configs.sh fails

Jason Gustafson created KAFKA-6656: -- Summary: Use non-zero status code when kafka-configs.sh fails Key: KAFKA-6656 URL: https://issues.apache.org/jira/browse/KAFKA-6656 Project: Kafka Issue

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

See Changes: [jason] MINOR: Correct "exeption" to "exception" in connect docs (#4709) -- [...truncated 416.62 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > should

Re: Add me to contributor list

Hi, Jimin, Thanks for your interest. Added you to the contributor list. Jun On Wed, Mar 14, 2018 at 3:17 AM, Jimin Hsieh wrote: > Hi, > > Would it be possible to add me to the contributor list? My jira username: > JiminHsieh > > Thanks, > Jimin Hsieh >

[jira] [Created] (KAFKA-6657) Add StreamsConfig prefix for different consumers

Matthias J. Sax created KAFKA-6657: -- Summary: Add StreamsConfig prefix for different consumers Key: KAFKA-6657 URL: https://issues.apache.org/jira/browse/KAFKA-6657 Project: Kafka Issue Type

[jira] [Created] (KAFKA-6658) Fix RoundTripWorkload and make k/v generation configurable

Colin P. McCabe created KAFKA-6658: -- Summary: Fix RoundTripWorkload and make k/v generation configurable Key: KAFKA-6658 URL: https://issues.apache.org/jira/browse/KAFKA-6658 Project: Kafka

Add me to the contributor list

Hi Could you please add me to the contributor list? My jira name is Sindiri. Thanks, Sirisha Sindiri

[jira] [Created] (KAFKA-6659) Improve error message if state store is not found

Matthias J. Sax created KAFKA-6659: -- Summary: Improve error message if state store is not found Key: KAFKA-6659 URL: https://issues.apache.org/jira/browse/KAFKA-6659 Project: Kafka Issue Typ

Re: Add me to the contributor list

Hi, Sirisha, Thanks for your interest. Just added you to the contributor list. Jun On Wed, Mar 14, 2018 at 12:05 PM, Sirisha Sindiri wrote: > Hi > > Could you please add me to the contributor list? > My jira name is Sindiri. > > Thanks, > Sirisha Sindiri >

[jira] [Created] (KAFKA-6660) Monitoring number of messages expired due to retention policy

Matt Garbis created KAFKA-6660: -- Summary: Monitoring number of messages expired due to retention policy Key: KAFKA-6660 URL: https://issues.apache.org/jira/browse/KAFKA-6660 Project: Kafka Issu

Re: Add me to the contributor list

Thank you Jun !! I am trying to assign https://issues.apache.org/jira/browse/SPARK-23685 to myself but I could not. Will you be able to help me out? Thanks, Sirisha On Wed, Mar 14, 2018 at 3:20 PM, Jun Rao wrote: > Hi, Sirisha, > > Thanks for your interest. Just added you to the contributor lis

Re: Add me to the contributor list

Hi, Sirisha, I could only add you to the Kafka contributor list. For Spark jiras, you would need to ask permission from Spark committers. Thanks, Jun On Wed, Mar 14, 2018 at 1:49 PM, Sirisha Sindiri wrote: > Thank you Jun !! > I am trying to assign https://issues.apache.org/jira/browse/SPARK-

Re: Add me to the contributor list

Sure Thank you!! On Wed, Mar 14, 2018 at 3:51 PM, Jun Rao wrote: > Hi, Sirisha, > > I could only add you to the Kafka contributor list. For Spark jiras, you > would need to ask permission from Spark committers. > > Thanks, > > Jun > > On Wed, Mar 14, 2018 at 1:49 PM, Sirisha Sindiri < > sirisha.

[jira] [Resolved] (KAFKA-6655) CleanupThread] Failed to lock the state directory due to an unexpected exception

[ https://issues.apache.org/jira/browse/KAFKA-6655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6655. Resolution: Duplicate > CleanupThread] Failed to lock the state directory due to an unexpect

Re: [VOTE] 1.1.0 RC2

+1 Ran tests Ran a 3 node cluster to test basic operations. Thanks, Harsha On Wed, Mar 14, 2018, at 9:04 AM, Ted Yu wrote: > +1 > > Ran test suite - passed (apart from testMetricsLeak which is flaky). > > On Wed, Mar 14, 2018 at 3:30 AM, Damian Guy wrote: > > > Thanks for pointing out Satish.

Re: [DISCUSS] KIP-257 - Configurable Quota Management

Hi, Rajini, Thanks for the KIP. Looks good overall. A few comments below. 10. "If quota config is used, *user* tag is set to user principal of the session and *client-id* tag is set to empty string. " Could we just omit such a tag if the value is empty? 11. I think Viktor has a valid point on h

[jira] [Resolved] (KAFKA-6640) Improve efficiency of KafkaAdminClient.describeTopics()

[ https://issues.apache.org/jira/browse/KAFKA-6640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6640. Resolution: Fixed Fix Version/s: 1.2.0 > Improve efficiency of KafkaAdminClient.descr

[jira] [Created] (KAFKA-6661) Sink connectors that explicitly 'resume' topic partitions can resume a paused task

Randall Hauch created KAFKA-6661: Summary: Sink connectors that explicitly 'resume' topic partitions can resume a paused task Key: KAFKA-6661 URL: https://issues.apache.org/jira/browse/KAFKA-6661 Proj

Re: [DISCUSS] KIP-257 - Configurable Quota Management

Hi Jun, Thank you for reviewing the KIP. 10. This is the current behaviour (this KIP retains the same behaviour for the default quota callback). We include 'user' and 'client-id' tags in all the quota metrics, rather than omit tags at the moment. 11. Ah, I hadn't realised that. I wasn't expectin

Re: [DISCUSSION] KIP-266: Add TimeoutException to KafkaConsumer#position()

Note to all: I have included bounding commitSync() and committed() in this KIP. On Sun, Mar 11, 2018 at 5:05 PM, Richard Yu wrote: > Hi all, > > I updated the KIP where overloading position() is now the favored approach. > Bounding position() using requestTimeoutMs has been listed as rejected. >

[jira] [Reopened] (KAFKA-6592) NullPointerException thrown when executing ConsoleCosumer with deserializer set to `WindowedDeserializer`

[ https://issues.apache.org/jira/browse/KAFKA-6592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-6592: -- > NullPointerException thrown when executing ConsoleCosumer with deserializer > set to `WindowedDes

Jenkins build is back to normal : kafka-trunk-jdk9 #475

See

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

See Changes: [jason] KAFKA-6640; Improve efficiency of KafkaAdminClient.describeTopics() [matthias] MINOR: fixing streams test-util compilation errors in Eclipse (#4631) -- [

Build failed in Jenkins: kafka-trunk-jdk7 #3255

See Changes: [jason] KAFKA-6640; Improve efficiency of KafkaAdminClient.describeTopics() [mjsax] MINOR: fixing streams test-util compilation errors in Eclipse (#4631) --

Re: [VOTE] 1.1.0 RC2

+1 (non-binding) - Ran testAll/releaseTarGzAll on 1.1.0-RC2 tag - Ran through quickstart of core/streams - Ran a cluster from binaries built form sources - with multiple operations. Thanks, Satish. On Thu, Mar 15, 2018 at 3:25 AM, Harsha wrote: > +1 > Ran tests > Ran a 3 node cluster to

Jenkins build is back to normal : kafka-trunk-jdk8 #2476

See

Build failed in Jenkins: kafka-trunk-jdk7 #3256

See Changes: [github] KAFKA-4831: add documentation for KIP-265 (#4686) -- [...truncated 419.46 KB...] kafka.api.SaslClientsWithInvalidCredentialsTest > testKafkaAdminCl

Re: [DISCUSS] KIP-258: Allow to Store Record Timestamps in RocksDB

After some more thoughts, I want to follow John's suggestion and split upgrading the rebalance metadata from the store upgrade. I extracted the metadata upgrade into it's own KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-268%3A+Simplify+Kafka+Streams+Rebalance+Metadata+Upgrade I'll u

[DISCUSS] KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade

Hi, I want to propose KIP-268 to allow rebalance metadata version upgrades in Kafka Streams: https://cwiki.apache.org/confluence/display/KAFKA/KIP-268%3A+Simplify+Kafka+Streams+Rebalance+Metadata+Upgrade Looking forward to your feedback. -Matthias signature.asc Description: OpenPGP digital

[jira] [Created] (KAFKA-6662) Consumer use offsetsForTimes() get offset return None.

Matt Wang created KAFKA-6662: Summary: Consumer use offsetsForTimes() get offset return None. Key: KAFKA-6662 URL: https://issues.apache.org/jira/browse/KAFKA-6662 Project: Kafka Issue Type: Bug