[jira] [Updated] (KAFKA-3724) Replace inter.broker.protocol.version with KIP-35 based version detection

[ https://issues.apache.org/jira/browse/KAFKA-3724?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-3724: Issue Type: Improvement (was: Bug) > Replace inter.broker.protocol.version with KIP-35 based versio

[jira] [Created] (KAFKA-3724) Replace inter.broker.protocol.version with KIP-35 based version detection

Gwen Shapira created KAFKA-3724: --- Summary: Replace inter.broker.protocol.version with KIP-35 based version detection Key: KAFKA-3724 URL: https://issues.apache.org/jira/browse/KAFKA-3724 Project: Kafka

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

See Changes: [junrao] KAFKA-3721; Put UpdateMetadataRequest V2 in 0.10.0-IV1 -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-us1 (Ubuntu

[VOTE] 0.10.0.0 RC6

Hello Kafka users, developers and client-developers, This is the seventh (!) candidate for release of Apache Kafka 0.10.0.0. This is a major release that includes: (1) New message format including timestamps (2) client interceptor API (3) Kafka Streams. This RC was rolled out to fix an issue with

Jenkins build is back to normal : kafka-trunk-jdk7 #1301

See

Build failed in Jenkins: kafka-0.10.0-jdk7 #98

See Changes: [junrao] KAFKA-3721; Put UpdateMetadataRequest V2 in 0.10.0-IV1 -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H10 (docker Ubuntu

[jira] [Updated] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3721: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 1400 [https:

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288178#comment-15288178 ] ASF GitHub Bot commented on KAFKA-3721: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-3721: Put UpdateMetadataRequest V2 in 0....

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1400 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

Re: [VOTE] 0.10.0.0 RC5

Holding off for another blocker: https://github.com/apache/kafka/pull/1400 On Tue, May 17, 2016 at 12:48 PM, Gwen Shapira wrote: > Yeah, this means another RC. > > Lets try to roll one out later today. > > On Tue, May 17, 2016 at 12:43 PM, Ewen Cheslack-Postava > wrote: >> FYI, there's a blocker

Build failed in Jenkins: kafka-0.10.0-jdk7 #97

See Changes: [cshapi] MINOR: Exclude jline, netty and findbugs annotations -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H10 (docker Ubuntu ub

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

See Changes: [cshapi] MINOR: Exclude jline, netty and findbugs annotations -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubunt

[GitHub] kafka pull request: MINOR: Exclude jline, netty and findbugs annot...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1396 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

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

See Changes: [ismael] KAFKA-3393; Updated the docs to reflect the deprecation of -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H10 (docker Ub

[jira] [Issue Comment Deleted] (KAFKA-3723) Cannot change size of schema cache for JSON converter

[ https://issues.apache.org/jira/browse/KAFKA-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Christian Posta updated KAFKA-3723: --- Comment: was deleted (was: Pull request on github: https://github.com/apache/kafka/pull/1401)

[jira] [Commented] (KAFKA-3723) Cannot change size of schema cache for JSON converter

[ https://issues.apache.org/jira/browse/KAFKA-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288059#comment-15288059 ] Christian Posta commented on KAFKA-3723: Pull request on github: https://github.c

[GitHub] kafka pull request: KAFKA-3723 Cannot change size of schema cache ...

GitHub user christian-posta opened a pull request: https://github.com/apache/kafka/pull/1401 KAFKA-3723 Cannot change size of schema cache for JSON converter You can merge this pull request into a Git repository by running: $ git pull https://github.com/christian-posta/kafka

[jira] [Commented] (KAFKA-3723) Cannot change size of schema cache for JSON converter

[ https://issues.apache.org/jira/browse/KAFKA-3723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288058#comment-15288058 ] ASF GitHub Bot commented on KAFKA-3723: --- GitHub user christian-posta opened a pull r

[jira] [Commented] (KAFKA-3055) JsonConverter mangles schema during serialization (fromConnectData)

[ https://issues.apache.org/jira/browse/KAFKA-3055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288056#comment-15288056 ] Christian Posta commented on KAFKA-3055: the correct config for the worker to chan

[jira] [Created] (KAFKA-3723) Cannot change size of schema cache for JSON converter

Christian Posta created KAFKA-3723: -- Summary: Cannot change size of schema cache for JSON converter Key: KAFKA-3723 URL: https://issues.apache.org/jira/browse/KAFKA-3723 Project: Kafka Issue

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288052#comment-15288052 ] Gwen Shapira commented on KAFKA-3721: - I'm ok with whatever [~ijuma] recommends. > Up

[jira] [Updated] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3721: Status: Patch Available (was: Open) > UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288045#comment-15288045 ] Jiangjie Qin commented on KAFKA-3721: - [~gwenshap] [~ijuma] I just submitted PR. The c

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288042#comment-15288042 ] ASF GitHub Bot commented on KAFKA-3721: --- GitHub user becketqin opened a pull request

[GitHub] kafka pull request: KAFKA-3721: Put UpdateMetadataRequest V2 in 0....

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1400 KAFKA-3721: Put UpdateMetadataRequest V2 in 0.10.0-IV1 You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-3721 Alternative

[jira] [Created] (KAFKA-3722) PlaintextChannelBuilder should not use ChannelBuilders.createPrincipalBuilder(configs) for creating instance of PrincipalBuilder

Mayuresh Gharat created KAFKA-3722: -- Summary: PlaintextChannelBuilder should not use ChannelBuilders.createPrincipalBuilder(configs) for creating instance of PrincipalBuilder Key: KAFKA-3722 URL: https://issues.

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288035#comment-15288035 ] Jiangjie Qin commented on KAFKA-3721: - I am fine either way. My understanding of the o

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288024#comment-15288024 ] Ismael Juma commented on KAFKA-3721: [~becket_qin], are you intending to provide a PR

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288022#comment-15288022 ] Ismael Juma commented on KAFKA-3721: Btw, I think it's fine to name it KAFKA_0_10_0 no

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288017#comment-15288017 ] Gwen Shapira commented on KAFKA-3721: - I guess we had different plans :) At this stag

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288007#comment-15288007 ] Ismael Juma commented on KAFKA-3721: As I understand, Jun's idea was for it to survive

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288003#comment-15288003 ] Gwen Shapira commented on KAFKA-3721: - I think the IV was intended as "intermediate ve

[jira] [Commented] (KAFKA-3393) Update site docs and javadoc based on max.block.ms changes

[ https://issues.apache.org/jira/browse/KAFKA-3393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15288001#comment-15288001 ] ASF GitHub Bot commented on KAFKA-3393: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-3393) Update site docs and javadoc based on max.block.ms changes

[ https://issues.apache.org/jira/browse/KAFKA-3393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-3393. Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1060 [https://github

[GitHub] kafka pull request: KAFKA-3393 : Updated the docs to reflect the d...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1060 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287999#comment-15287999 ] Jiangjie Qin commented on KAFKA-3721: - Hi Gwen, currently "0.10.0" is always pointing

[jira] [Commented] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

[ https://issues.apache.org/jira/browse/KAFKA-3721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287989#comment-15287989 ] Gwen Shapira commented on KAFKA-3721: - Since we are now releasing - can we modify the

[jira] [Created] (KAFKA-3721) UpdateMetadataRequest V2 should be in API version 0.10.0-IV1

Jiangjie Qin created KAFKA-3721: --- Summary: UpdateMetadataRequest V2 should be in API version 0.10.0-IV1 Key: KAFKA-3721 URL: https://issues.apache.org/jira/browse/KAFKA-3721 Project: Kafka Iss

[GitHub] kafka-site pull request: MINOR: Replace Scala style guide PDF link...

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/13 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is e

[GitHub] kafka-site pull request: MINOR: Replace Scala style guide PDF link...

Github user ijuma commented on the pull request: https://github.com/apache/kafka-site/pull/13#issuecomment-219895048 Thanks, LGTM. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[jira] [Commented] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287937#comment-15287937 ] Ismael Juma commented on KAFKA-3720: And probably deprecate `BufferExhaustedException`

[jira] [Created] (KAFKA-3720) Remove BufferExhaustException from doSend() in KafkaProducer

Mayuresh Gharat created KAFKA-3720: -- Summary: Remove BufferExhaustException from doSend() in KafkaProducer Key: KAFKA-3720 URL: https://issues.apache.org/jira/browse/KAFKA-3720 Project: Kafka

[jira] [Updated] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3554: Status: Patch Available (was: Open) > Generate actual data with specific compression ratio and add

[jira] [Commented] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287878#comment-15287878 ] ASF GitHub Bot commented on KAFKA-3554: --- GitHub user becketqin opened a pull request

[GitHub] kafka pull request: KAFKA-3554 Improve ProducerPerformance test

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1399 KAFKA-3554 Improve ProducerPerformance test 1. Added multiple thread support. 2. Added value-bound to make compressed data more realistic. 3. Print out the producer metrics. You can merge

[jira] [Assigned] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Edoardo Comar reassigned KAFKA-3396: Assignee: Edoardo Comar > Unauthorized topics are returned to the user > --

[jira] [Commented] (KAFKA-3396) Unauthorized topics are returned to the user

[ https://issues.apache.org/jira/browse/KAFKA-3396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287873#comment-15287873 ] Edoardo Comar commented on KAFKA-3396: -- Hi [~granthenke] we're still working on it,

[jira] [Commented] (KAFKA-3443) Support regex topics in addSource() and stream()

[ https://issues.apache.org/jira/browse/KAFKA-3443?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287764#comment-15287764 ] Bill Bejeck commented on KAFKA-3443: Status update - still actively working on this an

[jira] [Updated] (KAFKA-3717) Support building aggregate javadoc for all project modules

[ https://issues.apache.org/jira/browse/KAFKA-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3717: --- Reviewer: Gwen Shapira Status: Patch Available (was: In Progress) > Support building aggregate

[jira] [Commented] (KAFKA-3717) Support building aggregate javadoc for all project modules

[ https://issues.apache.org/jira/browse/KAFKA-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287604#comment-15287604 ] ASF GitHub Bot commented on KAFKA-3717: --- GitHub user ijuma opened a pull request:

[GitHub] kafka pull request: KAFKA-3717; Support building aggregate javadoc...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1398 KAFKA-3717; Support building aggregate javadoc for all project modules The task is called `javadocAll` and the generated html will be under `/build/docs/javadoc/`. I disabled javadoc for `too

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

See

[jira] [Commented] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

[ https://issues.apache.org/jira/browse/KAFKA-3719?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287422#comment-15287422 ] Gwen Shapira commented on KAFKA-3719: - AFAIK, underscores are not legal in hostnames.

Re: [VOTE] 0.10.0.0 RC5

Yeah, this means another RC. Lets try to roll one out later today. On Tue, May 17, 2016 at 12:43 PM, Ewen Cheslack-Postava wrote: > FYI, there's a blocker issue with this RC due to Apache licensing > restrictions. One of Connect's dependencies transitively includes the > findbugs annotations jar

Re: [VOTE] 0.10.0.0 RC5

FYI, there's a blocker issue with this RC due to Apache licensing restrictions. One of Connect's dependencies transitively includes the findbugs annotations jar, which is used for static analysis. Luckily it doesn't affect functionality and looks like it can easily be filtered out. We also discover

[jira] [Comment Edited] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286887#comment-15286887 ] Guozhang Wang edited comment on KAFKA-3704 at 5/17/16 6:52 PM: -

[jira] [Commented] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287273#comment-15287273 ] Ismael Juma commented on KAFKA-3704: I agree [~guozhang]. > Improve mechanism for com

Re: [DISCUSS] KIP-58 - Make Log Compaction Point Configurable

and Spark's implementation is another good reason to allow compaction lag. I'm convinced :) We need to decide: 1) Do we need just .ms config, or anything else? consumer lag is measured (and monitored) in messages, so if we need this feature to somehow work in tandem with consumer lag monito

[GitHub] kafka pull request: KAFKA-3716: Validate all timestamps are not ne...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1393 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3716) Check against negative timestamps

[ https://issues.apache.org/jira/browse/KAFKA-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15287195#comment-15287195 ] ASF GitHub Bot commented on KAFKA-3716: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-3716) Check against negative timestamps

[ https://issues.apache.org/jira/browse/KAFKA-3716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3716. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request 1393 [https://gi

[jira] [Closed] (KAFKA-3219) Long topic names mess up broker topic state

[ https://issues.apache.org/jira/browse/KAFKA-3219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian closed KAFKA-3219. -- > Long topic names mess up broker topic state > --- > >

Re: [DISCUSS] KIP-58 - Make Log Compaction Point Configurable

James, Your pictures do an excellent job of illustrating my point. My mention of the additional "10's of minutes to hours" refers to how far after the original target checkpoint (T1 in your diagram) on may need to go to get to a checkpoint where all partitions of all topics are in the uncompac

[jira] [Assigned] (KAFKA-3554) Generate actual data with specific compression ratio and add multi-thread support in the ProducerPerformance tool.

[ https://issues.apache.org/jira/browse/KAFKA-3554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-3554: --- Assignee: Jiangjie Qin (was: Dong Lin) > Generate actual data with specific compression rati

[jira] [Created] (KAFKA-3719) Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow

Balazs Kossovics created KAFKA-3719: --- Summary: Pattern regex org.apache.kafka.common.utils.Utils.HOST_PORT_PATTERN is too narrow Key: KAFKA-3719 URL: https://issues.apache.org/jira/browse/KAFKA-3719

[GitHub] kafka pull request: MINOR: Bump system test ducktape dependency to...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/1397 MINOR: Bump system test ducktape dependency to 0.5.1 You can merge this pull request into a Git repository by running: $ git pull https://github.com/granders/kafka minor-increment-ducktape A

[GitHub] kafka-site pull request: MINOR: Replace Scala style guide PDF link...

Github user RyanCoonan commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/13#discussion_r63553295 --- Diff: coding-guide.html --- @@ -19,7 +19,7 @@ Scala -We are following the style guide given http://davetron5000.github.com/scala

[GitHub] kafka-site pull request: MINOR: Replace Scala style guide PDF link...

Github user ijuma commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/13#discussion_r63552659 --- Diff: coding-guide.html --- @@ -19,7 +19,7 @@ Scala -We are following the style guide given http://davetron5000.github.com/scala-styl

[GitHub] kafka-site pull request: MINOR: Fix typos and formatting in coding...

Github user RyanCoonan closed the pull request at: https://github.com/apache/kafka-site/pull/14 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[GitHub] kafka-site pull request: MINOR: Replace Scala style guide PDF link...

Github user RyanCoonan commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/13#discussion_r63551060 --- Diff: coding-guide.html --- @@ -19,7 +19,7 @@ Scala -We are following the style guide given http://davetron5000.github.com/scala

[jira] [Work started] (KAFKA-3717) Support building aggregate javadoc for all project modules

[ https://issues.apache.org/jira/browse/KAFKA-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-3717 started by Ismael Juma. -- > Support building aggregate javadoc for all project modules > --

[jira] [Commented] (KAFKA-3717) Support building aggregate javadoc for all project modules

[ https://issues.apache.org/jira/browse/KAFKA-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286897#comment-15286897 ] Ismael Juma commented on KAFKA-3717: I had a chat with Grant and he said it was OK for

[jira] [Assigned] (KAFKA-3717) Support building aggregate javadoc for all project modules

[ https://issues.apache.org/jira/browse/KAFKA-3717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reassigned KAFKA-3717: -- Assignee: Ismael Juma (was: Grant Henke) > Support building aggregate javadoc for all project

[jira] [Commented] (KAFKA-3704) Improve mechanism for compression stream block size selection in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15286887#comment-15286887 ] Guozhang Wang commented on KAFKA-3704: -- Thanks for the summary [~ijuma]. I think 2)

Perf producer/consumers for compacted topics

Hi there, As noted in the 0.10.0.0-RC4 release thread, we (Heroku Kafka) have been doing extensive benchmarking of Kafka. In our case this is to help give customers a good idea of the performance of our various configurations. For this we orchestrate the Kafka `producer-perf.sh` and `consumer-perf

[GitHub] kafka pull request: MINOR: Exclude `jline` and `netty` dependencie...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1396 MINOR: Exclude `jline` and `netty` dependencies in the `streams` project These dependencies are unnecessary and they are acquired transitively via the zkclient dependency. The approach taken is

[jira] [Updated] (KAFKA-3418) Add section on detecting consumer failures in new consumer javadoc

[ https://issues.apache.org/jira/browse/KAFKA-3418?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3418: --- Fix Version/s: (was: 0.10.1.0) > Add section on detecting consumer failures in new consumer javado

[jira] [Updated] (KAFKA-3384) bin scripts may not be portable/POSIX compliant

[ https://issues.apache.org/jira/browse/KAFKA-3384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3384: --- Fix Version/s: (was: 0.10.1.0) > bin scripts may not be portable/POSIX compliant > ---

[jira] [Updated] (KAFKA-3451) Add basic HTML coverage report generation to gradle

[ https://issues.apache.org/jira/browse/KAFKA-3451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3451: --- Fix Version/s: (was: 0.10.1.0) > Add basic HTML coverage report generation to gradle > ---

[jira] [Updated] (KAFKA-3439) Document possible exception thrown in public APIs

[ https://issues.apache.org/jira/browse/KAFKA-3439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3439: --- Fix Version/s: (was: 0.10.1.0) > Document possible exception thrown in public APIs > -

[jira] [Updated] (KAFKA-3426) Improve protocol type errors when invalid sizes are received

[ https://issues.apache.org/jira/browse/KAFKA-3426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3426: --- Fix Version/s: (was: 0.10.1.0) > Improve protocol type errors when invalid sizes are received > --

[jira] [Updated] (KAFKA-3434) Add old ConsumerRecord constructor for compatibility

[ https://issues.apache.org/jira/browse/KAFKA-3434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3434: --- Fix Version/s: (was: 0.10.1.0) > Add old ConsumerRecord constructor for compatibility > --

[jira] [Updated] (KAFKA-3382) Add system test for ReplicationVerificationTool

[ https://issues.apache.org/jira/browse/KAFKA-3382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3382: --- Fix Version/s: (was: 0.10.1.0) > Add system test for ReplicationVerificationTool > ---

[jira] [Updated] (KAFKA-3381) Add system test for SimpleConsumerShell

[ https://issues.apache.org/jira/browse/KAFKA-3381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3381: --- Fix Version/s: (was: 0.10.1.0) > Add system test for SimpleConsumerShell > ---

[jira] [Updated] (KAFKA-1720) [Renaming / Comments] Delayed Operations

[ https://issues.apache.org/jira/browse/KAFKA-1720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1720: --- Fix Version/s: (was: 0.10.1.0) 0.9.0.0 > [Renaming / Comments] Delayed Operatio

[jira] [Updated] (KAFKA-1483) Split Brain about Leader Partitions

[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1483: --- Fix Version/s: (was: 0.10.1.0) 0.8.2.0 > Split Brain about Leader Partitions >

[jira] [Updated] (KAFKA-1536) Change the status of the JIRA to "Patch Available" in the kafka-review-tool

[ https://issues.apache.org/jira/browse/KAFKA-1536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1536: --- Fix Version/s: (was: 0.10.1.0) > Change the status of the JIRA to "Patch Available" in the kafka-r

[jira] [Updated] (KAFKA-3435) Remove `Unstable` annotation from new Java Consumer

[ https://issues.apache.org/jira/browse/KAFKA-3435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3435: --- Fix Version/s: (was: 0.10.1.0) > Remove `Unstable` annotation from new Java Consumer > ---

[jira] [Updated] (KAFKA-1445) New Producer should send all partitions that have non-empty batches when on of them is ready

[ https://issues.apache.org/jira/browse/KAFKA-1445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1445: --- Fix Version/s: (was: 0.10.1.0) 0.8.2.0 > New Producer should send all partition

[jira] [Updated] (KAFKA-3488) commitAsync() fails if metadata update creates new SASL/SSL connection

[ https://issues.apache.org/jira/browse/KAFKA-3488?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3488: --- Fix Version/s: (was: 0.10.1.0) > commitAsync() fails if metadata update creates new SASL/SSL conne

[jira] [Updated] (KAFKA-3464) Connect security system tests

[ https://issues.apache.org/jira/browse/KAFKA-3464?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3464: --- Fix Version/s: (was: 0.10.1.0) > Connect security system tests > - > >

[jira] [Updated] (KAFKA-3459) Returning zero task configurations from a connector does not properly clean up existing tasks

[ https://issues.apache.org/jira/browse/KAFKA-3459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3459: --- Fix Version/s: (was: 0.10.1.0) > Returning zero task configurations from a connector does not prop

[jira] [Updated] (KAFKA-3483) Restructure ducktape tests to simplify running subsets of tests

[ https://issues.apache.org/jira/browse/KAFKA-3483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3483: --- Fix Version/s: (was: 0.10.1.0) > Restructure ducktape tests to simplify running subsets of tests >

[jira] [Updated] (KAFKA-3490) Multiple version support for ducktape performance tests

[ https://issues.apache.org/jira/browse/KAFKA-3490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3490: --- Fix Version/s: (was: 0.10.1.0) > Multiple version support for ducktape performance tests > ---

[jira] [Updated] (KAFKA-3495) `NetworkClient.blockingSendAndReceive` should rely on requestTimeout

[ https://issues.apache.org/jira/browse/KAFKA-3495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3495: --- Fix Version/s: (was: 0.10.1.0) > `NetworkClient.blockingSendAndReceive` should rely on requestTime

[jira] [Updated] (KAFKA-3505) Set curRecord in punctuate() functions

[ https://issues.apache.org/jira/browse/KAFKA-3505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3505: --- Fix Version/s: (was: 0.10.1.0) > Set curRecord in punctuate() functions >

[jira] [Updated] (KAFKA-3506) Kafka Connect Task Restart API

[ https://issues.apache.org/jira/browse/KAFKA-3506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3506: --- Fix Version/s: (was: 0.10.1.0) > Kafka Connect Task Restart API > -- >

[jira] [Updated] (KAFKA-3520) System tests of config validate and list connectors REST APIs

[ https://issues.apache.org/jira/browse/KAFKA-3520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3520: --- Fix Version/s: (was: 0.10.1.0) > System tests of config validate and list connectors REST APIs > -

[jira] [Updated] (KAFKA-3508) Transient failure in kafka.security.auth.SimpleAclAuthorizerTest.testHighConcurrencyModificationOfResourceAcls

[ https://issues.apache.org/jira/browse/KAFKA-3508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3508: --- Fix Version/s: (was: 0.10.1.0) > Transient failure in > kafka.security.auth.SimpleAclAuthorizerTe

[jira] [Updated] (KAFKA-3307) Add ApiVersion request/response and server side handling.

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3307: --- Fix Version/s: (was: 0.10.1.0) > Add ApiVersion request/response and server side handling. > -

  1   2   >