[jira] [Commented] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173295#comment-15173295 ] Jun Rao commented on KAFKA-3310: [~aauradkar], that depends. In this case, the NPE is triggered directly

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

See Changes: [junrao] KAFKA-3273; MessageFormatter and MessageReader interfaces should be -- [...truncated 5623 lines...] org.apache.kafka.connect.storage.KafkaOffsetBackingStoreTest >

[jira] [Commented] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173223#comment-15173223 ] Aditya Auradkar commented on KAFKA-3310: [~junrao] - Just making sure, you observe that the

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

See Changes: [junrao] KAFKA-3273; MessageFormatter and MessageReader interfaces should be -- [...truncated 5651 lines...] org.apache.kafka.connect.runtime.WorkerTaskTest > stopBeforeStarting

[jira] [Commented] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15173204#comment-15173204 ] Aditya Auradkar commented on KAFKA-3310: [~junrao] - Let me investigate this. If this is a

Re: [VOTE] KIP-33 - Add a time based log index to Kafka

Hi Jun, I think index.interval.bytes is used to control the density of the offset index. The counterpart of index.interval.bytes for time index is time.index.interval.ms. If we did not change the semantic of log.roll.ms, log.roll.ms/time.index.interval.ms and

[jira] [Commented] (KAFKA-3273) MessageFormatter and MessageReader interfaces should be resilient to changes

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

[jira] [Updated] (KAFKA-3273) MessageFormatter and MessageReader interfaces should be resilient to changes

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

[GitHub] kafka pull request: KAFKA-3273; MessageFormatter and MessageReader...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/972 --- 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

Re: [DISCUSS] KIP-43: Kafka SASL enhancements

Rajini, Thanks for the updates. Just a couple of minor comments. 1. With the default GSSAPI, what's the first packet that the client sends to the server? Is that completely different from the packet format that we will use for non-GSSAPI mechanisms? 2. In the server response, it doesn't seem

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

See Changes: [wangguoz] MINOR: Add AUTO_OFFSET_RESET_CONFIG to StreamsConfig; remove [wangguoz] MINOR: DefaultMessageFormatter custom deserializer fixes -- [...truncated 4994 lines...]

Re: [VOTE] KIP-33 - Add a time based log index to Kafka

Hi, Becket, I thought that your proposal to build time-based index just based off index.interval.bytes is reasonable. Is there a particular need to also add time. index.interval.bytes? Compute the pre-allocated index file size based on log segment file size can be useful. However, the tricky

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

See Changes: [wangguoz] MINOR: Add AUTO_OFFSET_RESET_CONFIG to StreamsConfig; remove [wangguoz] MINOR: DefaultMessageFormatter custom deserializer fixes -- [...truncated 129 lines...]

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

See Changes: [wangguoz] KAFKA-3192: Add unwindowed aggregations for KStream; and make all -- [...truncated 1483 lines...] kafka.integration.AutoOffsetResetTest >

[GitHub] kafka pull request: MINOR: DefaultMessageFormatter custom deserial...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/987 --- 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

Re: [DISCUSS] KIP-35 - Retrieve protocol version

This is a fantastic and much-needed KIP. All third-party clients have had to deal with this issue. In my experience most clients are either declaring they only support version broker version X, or are spending a lot of time hacking around the issue. I think the community of non-java drivers would

[jira] [Commented] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

[ https://issues.apache.org/jira/browse/KAFKA-3310?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172950#comment-15172950 ] Jun Rao commented on KAFKA-3310: [~aauradkar], do you think this is a problem? > fetch requests can

[jira] [Created] (KAFKA-3310) fetch requests can trigger repeated NPE when quota is enabled

Jun Rao created KAFKA-3310: -- Summary: fetch requests can trigger repeated NPE when quota is enabled Key: KAFKA-3310 URL: https://issues.apache.org/jira/browse/KAFKA-3310 Project: Kafka Issue Type:

[GitHub] kafka pull request: MINOR: add AUTO_OFFSET_RESET_CONFIG to Streams...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/985 --- 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

[GitHub] kafka pull request: MINOR: DefaultMessageFormatter custom deserial...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/987 MINOR: DefaultMessageFormatter custom deserializer fixes The ability to specify a deserializer for keys and values was added in a recent commit (845c6eae1f6c6bcf11), but it contained a few issues.

[jira] [Created] (KAFKA-3309) Update Protocol Documentation WIP patch

Ashish K Singh created KAFKA-3309: - Summary: Update Protocol Documentation WIP patch Key: KAFKA-3309 URL: https://issues.apache.org/jira/browse/KAFKA-3309 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-35 - Retrieve protocol version

I hope it is OK for me to make some progress here. I have made the following changes. 1. Updated KIP-35, to adopt Jay's suggestion on maintaining separate list of deprecated versions, instead of using a version of -1. 2. Added information on required permissions, Describe action on Cluster

[jira] [Created] (KAFKA-3308) Use ProtocolVersion during rolling upgrades to decide on a mutually agreed protocol version between brokers, eliminating the need of inter.broker.protocol.version.

Ashish K Singh created KAFKA-3308: - Summary: Use ProtocolVersion during rolling upgrades to decide on a mutually agreed protocol version between brokers, eliminating the need of inter.broker.protocol.version. Key: KAFKA-3308

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

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3307: -- Affects Version/s: 0.10.0.0 > Add ProtocolVersion request/response and server side handling. >

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

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3307: -- Status: Patch Available (was: Open) > Add ProtocolVersion request/response and server side

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

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172880#comment-15172880 ] ASF GitHub Bot commented on KAFKA-3307: --- GitHub user SinghAsDev reopened a pull request:

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

[ https://issues.apache.org/jira/browse/KAFKA-3307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172879#comment-15172879 ] ASF GitHub Bot commented on KAFKA-3307: --- Github user SinghAsDev closed the pull request at:

[GitHub] kafka pull request: KAFKA-3307: Add ProtocolVersion request/respon...

GitHub user SinghAsDev reopened a pull request: https://github.com/apache/kafka/pull/986 KAFKA-3307: Add ProtocolVersion request/response and server side handling. The patch does the following. 1. For unknown requests or protocol versions, broker sends an empty response,

[GitHub] kafka pull request: KAFKA-3307: Add ProtocolVersion request/respon...

Github user SinghAsDev closed the pull request at: https://github.com/apache/kafka/pull/986 --- 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

[GitHub] kafka pull request: Kafka 3307: Add ProtocolVersion request/respon...

GitHub user SinghAsDev opened a pull request: https://github.com/apache/kafka/pull/986 Kafka 3307: Add ProtocolVersion request/response and server side handling. You can merge this pull request into a Git repository by running: $ git pull https://github.com/SinghAsDev/kafka

[jira] [Commented] (KAFKA-2431) Test SSL/TLS impact on performance

[ https://issues.apache.org/jira/browse/KAFKA-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172875#comment-15172875 ] Simon Suo commented on KAFKA-2431: -- Hi all. This is Simon, a data infra intern working on LinkedIn's

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

Ashish K Singh created KAFKA-3307: - Summary: Add ProtocolVersion request/response and server side handling. Key: KAFKA-3307 URL: https://issues.apache.org/jira/browse/KAFKA-3307 Project: Kafka

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

See Changes: [wangguoz] KAFKA-3133: Add putIfAbsent function to KeyValueStore [wangguoz] HOTFIX: Missing streams jar in release -- [...truncated 5623 lines...]

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

See Changes: [wangguoz] KAFKA-3192: Add unwindowed aggregations for KStream; and make all -- [...truncated 5659 lines...] org.apache.kafka.connect.storage.KafkaConfigStorageTest >

[jira] [Commented] (KAFKA-3304) KIP-35 - Retrieving protocol version

[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172872#comment-15172872 ] Ashish K Singh commented on KAFKA-3304: --- Assigning the JIRA to myself. > KIP-35 - Retrieving

[jira] [Assigned] (KAFKA-3304) KIP-35 - Retrieving protocol version

[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh reassigned KAFKA-3304: - Assignee: Ashish K Singh > KIP-35 - Retrieving protocol version >

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172838#comment-15172838 ] Jiangjie Qin commented on KAFKA-3236: - [~tgraves] We had extensive discussion on the configurations in

[GitHub] kafka pull request: MINOR: add AUTO_OFFSET_RESET_CONFIG to Streams...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/985 MINOR: add AUTO_OFFSET_RESET_CONFIG to StreamsConfig, and remove TOTAL_RECORDS_TO_PROCESS @guozhangwang You can merge this pull request into a Git repository by running: $ git pull

[jira] [Resolved] (KAFKA-3289) Update Kafka protocol guide wiki for KIP-31 / KIP-32

[ https://issues.apache.org/jira/browse/KAFKA-3289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved KAFKA-3289. - Resolution: Fixed > Update Kafka protocol guide wiki for KIP-31 / KIP-32 >

[jira] [Created] (KAFKA-3306) Update metdata response to include required additional fields

Grant Henke created KAFKA-3306: -- Summary: Update metdata response to include required additional fields Key: KAFKA-3306 URL: https://issues.apache.org/jira/browse/KAFKA-3306 Project: Kafka

[jira] [Updated] (KAFKA-3306) Change metdata response to include required additional fields

[ https://issues.apache.org/jira/browse/KAFKA-3306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-3306: --- Summary: Change metdata response to include required additional fields (was: Update metdata response

Possible bug in Streams → KStreamImpl.java

I was just playing around with Streams’ join features, just to get a feel for them, and I think I may have noticed a bug in the code, in KStreamImpl.java on line 310:

[jira] [Created] (KAFKA-3305) JMX in AWS instance

Flavio Junqueira created KAFKA-3305: --- Summary: JMX in AWS instance Key: KAFKA-3305 URL: https://issues.apache.org/jira/browse/KAFKA-3305 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-3304) KIP-35 - Retrieving protocol version

[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-3304: -- Description: Uber JIRA to track adding of functionality to retrieve protocol versions. More

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172729#comment-15172729 ] ASF GitHub Bot commented on KAFKA-3236: --- Github user knusbaum closed the pull request at:

[jira] [Commented] (KAFKA-3236) Honor Producer Configuration "block.on.buffer.full"

[ https://issues.apache.org/jira/browse/KAFKA-3236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172730#comment-15172730 ] ASF GitHub Bot commented on KAFKA-3236: --- GitHub user knusbaum reopened a pull request:

[GitHub] kafka pull request: KAFKA-3236: Honor Producer Configuration "bloc...

Github user knusbaum closed the pull request at: https://github.com/apache/kafka/pull/934 --- 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

[GitHub] kafka pull request: KAFKA-3236: Honor Producer Configuration "bloc...

GitHub user knusbaum reopened a pull request: https://github.com/apache/kafka/pull/934 KAFKA-3236: Honor Producer Configuration "block.on.buffer.full" You can merge this pull request into a Git repository by running: $ git pull https://github.com/knusbaum/kafka

[jira] [Commented] (KAFKA-3304) KIP-35 - Retrieving protocol version

[ https://issues.apache.org/jira/browse/KAFKA-3304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172727#comment-15172727 ] Ashish K Singh commented on KAFKA-3304: --- [~edenhill] is it OK if I assign this JIRA to myself and

[jira] [Created] (KAFKA-3304) KIP-35 - Retrieving protocol version

Ashish K Singh created KAFKA-3304: - Summary: KIP-35 - Retrieving protocol version Key: KAFKA-3304 URL: https://issues.apache.org/jira/browse/KAFKA-3304 Project: Kafka Issue Type: Improvement

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

See Changes: [wangguoz] KAFKA-3133: Add putIfAbsent function to KeyValueStore [wangguoz] HOTFIX: Missing streams jar in release -- [...truncated 1474 lines...] kafka.log.LogTest >

[jira] [Commented] (KAFKA-2073) Replace TopicMetadata request/response with o.a.k.requests.metadata

[ https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172713#comment-15172713 ] Jason Gustafson commented on KAFKA-2073: [~abiletskyi] I went ahead and assigned this to myself.

[jira] [Assigned] (KAFKA-2073) Replace TopicMetadata request/response with o.a.k.requests.metadata

[ https://issues.apache.org/jira/browse/KAFKA-2073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-2073: -- Assignee: Jason Gustafson (was: Andrii Biletskyi) > Replace TopicMetadata

[jira] [Assigned] (KAFKA-3192) Add implicit unlimited windowed aggregation for KStream

[ https://issues.apache.org/jira/browse/KAFKA-3192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-3192: Assignee: Guozhang Wang > Add implicit unlimited windowed aggregation for KStream >

[GitHub] kafka pull request: KAFKA-3192: Add unwindowed aggregations for KS...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/870 --- 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

[jira] [Commented] (KAFKA-3192) Add implicit unlimited windowed aggregation for KStream

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

[jira] [Resolved] (KAFKA-3192) Add implicit unlimited windowed aggregation for KStream

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

[jira] [Commented] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172692#comment-15172692 ] Guozhang Wang commented on KAFKA-3133: -- Thanks for the patch [~kichristensen]. I have added you to

[jira] [Updated] (KAFKA-3229) Root statestore is not registered with ProcessorStateManager, inner state store is registered instead

[ https://issues.apache.org/jira/browse/KAFKA-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3229: - Assignee: Tom Dearman > Root statestore is not registered with ProcessorStateManager, inner state

[jira] [Updated] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

[ https://issues.apache.org/jira/browse/KAFKA-3133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3133: - Assignee: Kim Christensen > Add putIfAbsent function to KeyValueStore >

[jira] [Created] (KAFKA-3303) Pass partial record metadata to Interceptor onAcknowledgement in case of errors

Anna Povzner created KAFKA-3303: --- Summary: Pass partial record metadata to Interceptor onAcknowledgement in case of errors Key: KAFKA-3303 URL: https://issues.apache.org/jira/browse/KAFKA-3303 Project:

[jira] [Commented] (KAFKA-3229) Root statestore is not registered with ProcessorStateManager, inner state store is registered instead

[ https://issues.apache.org/jira/browse/KAFKA-3229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172592#comment-15172592 ] Guozhang Wang commented on KAFKA-3229: -- [~tom_dearman] I feel adding one more parameter to the

[GitHub] kafka pull request: HOTFIX: Missing streams jar in release

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/984 --- 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

[jira] [Commented] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

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

[jira] [Resolved] (KAFKA-3133) Add putIfAbsent function to KeyValueStore

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

[GitHub] kafka pull request: KAFKA-3133: Add putIfAbsent function to KeyVal...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/912 --- 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

[GitHub] kafka pull request: HOTFIX: Missing streams jar in release

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/984 HOTFIX: Missing streams jar in release Observation: when doing "gradlew releaseTarGz" the streams jar was not included in the tarball. Adding a line to include it. @ijuma @guozhangwang could

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

See Changes: [harsha] KAFKA-3291; DumpLogSegment tool should also provide an option to only… -- [...truncated 5025 lines...] org.apache.kafka.streams.processor.internals.RecordCollectorTest >

[jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately

[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15172416#comment-15172416 ] Jason Gustafson commented on KAFKA-3296: [~thecoop1984] Thanks for the logs. Is there only one

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

See Changes: [harsha] KAFKA-3291; DumpLogSegment tool should also provide an option to only… -- [...truncated 5617 lines...] org.apache.kafka.connect.storage.KafkaOffsetBackingStoreTest >

Re: [DISCUSS] KIP-43: Kafka SASL enhancements

Harsha, Thank you for the review. I will wait another day to see if there is more feedback and then start a voting thread. Rajini On Mon, Feb 29, 2016 at 2:51 PM, Harsha wrote: > Rajini, > Thanks for the changes to the KIP. It looks good to me. I >

[jira] [Created] (KAFKA-3302) Pass kerberos keytab and principal as part of client config

Sriharsha Chintalapani created KAFKA-3302: - Summary: Pass kerberos keytab and principal as part of client config Key: KAFKA-3302 URL: https://issues.apache.org/jira/browse/KAFKA-3302

[jira] [Updated] (KAFKA-3300) Calculate the initial/max size of offset index files and reduce the memory footprint for memory mapped index files.

[ https://issues.apache.org/jira/browse/KAFKA-3300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3300: Status: Patch Available (was: Open) > Calculate the initial/max size of offset index files and

[GitHub] kafka pull request: KAFKA-3291: DumpLogSegment tool should also pr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/975 --- 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

[jira] [Resolved] (KAFKA-3291) DumpLogSegment tool should also provide an option to only verify index sanity.

[ https://issues.apache.org/jira/browse/KAFKA-3291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-3291. --- Resolution: Fixed Fix Version/s: 0.10.0.0 Issue resolved by pull

[jira] [Commented] (KAFKA-3291) DumpLogSegment tool should also provide an option to only verify index sanity.

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

Re: [DISCUSS] KIP-49: Fair Partition Assignment Strategy

Thanks for the feedback. I have added a concrete example to the document that I think illustrates the benefit relatively well. The observation about scaling the workload of individual consumers is certainly valid. I had not really considered this. Our primary concern is being able to gradually

Re: [DISCUSS] KIP-43: Kafka SASL enhancements

Rajini, Thanks for the changes to the KIP. It looks good to me. I think we can move to voting. Thanks, Harsha On Mon, Feb 29, 2016, at 12:43 AM, Rajini Sivaram wrote: > I have added some more detail to the KIP based on the discussion in the > last KIP meeting to

[jira] [Updated] (KAFKA-3296) All consumer reads hang indefinately

[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Simon Cooper updated KAFKA-3296: Attachment: kafkalogs.zip These are debug logs from the broker when it's in this broken state >

[jira] [Comment Edited] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171787#comment-15171787 ] Robert Lowe edited comment on KAFKA-3218 at 2/29/16 11:58 AM: -- Using the PR

[jira] [Comment Edited] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171787#comment-15171787 ] Robert Lowe edited comment on KAFKA-3218 at 2/29/16 11:57 AM: -- Using the PR

[jira] [Commented] (KAFKA-3218) Kafka-0.9.0.0 does not work as OSGi module

[ https://issues.apache.org/jira/browse/KAFKA-3218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171787#comment-15171787 ] Robert Lowe commented on KAFKA-3218: Using the PR https://github.com/apache/kafka/pull/888 works in

[jira] [Commented] (KAFKA-3296) All consumer reads hang indefinately

[ https://issues.apache.org/jira/browse/KAFKA-3296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171739#comment-15171739 ] Simon Cooper commented on KAFKA-3296: - This is done right after kafka is installed on the VM - we

Re: [DISCUSS] KIP-43: Kafka SASL enhancements

I have added some more detail to the KIP based on the discussion in the last KIP meeting to simplify support for multiple mechanisms. Have also changed the property names to reflect this. Also updated the PR in https://issues.apache.org/jira/browse/KAFKA-3149 to reflect the KIP. Any feedback is