[jira] [Updated] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Fix Version/s: (was: 0.10.0.1) 0.10.0.0 > Wildcards in External CLASSPATH may cau

[jira] [Updated] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei updated KAFKA-3692: -- Priority: Blocker (was: Major) > Wildcards in External CLASSPATH may cause it not be included in the CL

[GitHub] kafka pull request: KAFKA-3421: Connect developer guide update and...

GitHub user Ishiihara opened a pull request: https://github.com/apache/kafka/pull/1366 KAFKA-3421: Connect developer guide update and several fixes This is a follow up of KAKFA-3421 to update the connect developer guide to include the configuration validation. Also includes a couple

[jira] [Commented] (KAFKA-3421) Update docs with new connector features

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

[GitHub] kafka pull request: KAFKA-3584; Fix synchronization issue between ...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/1367 KAFKA-3584; Fix synchronization issue between deleteOldSegments() and nd delete() methods calls This PR is to fix synchronization issue between deleteOldSegments() and delete() method calls. log.d

[jira] [Updated] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

[ https://issues.apache.org/jira/browse/KAFKA-3584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3584: --- Status: Patch Available (was: Open) > NullPointer Exception found when Delete Topic and Log d

[jira] [Commented] (KAFKA-3584) NullPointer Exception found when Delete Topic and Log delete concurrent

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

[jira] [Resolved] (KAFKA-3593) kafka.network.Processor throws ArrayIndexOutOfBoundsException

[ https://issues.apache.org/jira/browse/KAFKA-3593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3593. Resolution: Duplicate > kafka.network.Processor throws ArrayIndexOutOfBoundsException >

[jira] [Commented] (KAFKA-3647) Unable to set a ssl provider

[ https://issues.apache.org/jira/browse/KAFKA-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279926#comment-15279926 ] Elvar commented on KAFKA-3647: -- I agree, a better documentation would resolve both issues, ho

[jira] [Commented] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279945#comment-15279945 ] Rajini Sivaram commented on KAFKA-3689: --- [~buvana.rama...@nokia.com] Were there any

[jira] [Commented] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15279976#comment-15279976 ] Ismael Juma commented on KAFKA-3689: [~rsivaram], that's a good point. Are you going t

[GitHub] kafka pull request: MINOR: Ensure that selection key is cancelled ...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1368 MINOR: Ensure that selection key is cancelled on close You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka minor-channelcl

[jira] [Commented] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280019#comment-15280019 ] Rajini Sivaram commented on KAFKA-3689: --- [~ijuma] PR for the {{PlainTransportLayer.c

[jira] [Commented] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280021#comment-15280021 ] Ismael Juma commented on KAFKA-3689: [~rsivaram], thanks. On it. > ERROR Processor go

[jira] [Commented] (KAFKA-3700) CRL support

[ https://issues.apache.org/jira/browse/KAFKA-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280035#comment-15280035 ] Ismael Juma commented on KAFKA-3700: Thanks for filing the JIRA. Certificate revocatio

[jira] [Commented] (KAFKA-3700) CRL support

[ https://issues.apache.org/jira/browse/KAFKA-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280041#comment-15280041 ] Vincent Bernat commented on KAFKA-3700: --- A KIP would be too much work for me current

[jira] [Commented] (KAFKA-3700) CRL support

[ https://issues.apache.org/jira/browse/KAFKA-3700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280058#comment-15280058 ] Ismael Juma commented on KAFKA-3700: [~vbernat], that sounds good. We are about to rel

[GitHub] kafka pull request: MINOR: Ensure that selection key is cancelled ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1368 --- 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-3689) ERROR Processor got uncaught exception. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280108#comment-15280108 ] Buvaneswari Ramanan commented on KAFKA-3689: There were no exceptions/errors i

[jira] [Created] (KAFKA-3701) Expose KafkaStreams metrics in public API

Jeff Klukas created KAFKA-3701: -- Summary: Expose KafkaStreams metrics in public API Key: KAFKA-3701 URL: https://issues.apache.org/jira/browse/KAFKA-3701 Project: Kafka Issue Type: Improvement

Jenkins build is back to normal : kafka-0.10.0-jdk7 #77

See

[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=15280197#comment-15280197 ] Edoardo Comar commented on KAFKA-3396: -- Hi we have worked on a simple patch that wou

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280213#comment-15280213 ] Jun Rao commented on KAFKA-3565: Since that's an existing issue, perhaps file a new jira?

[GitHub] kafka pull request: MINOR: Documentation for Rack Awareness

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/1369 MINOR: Documentation for Rack Awareness You can merge this pull request into a Git repository by running: $ git pull https://github.com/benstopford/kafka rack-awareness-docs Alternatively

[GitHub] kafka pull request: MINOR: Documentation for Rack Awareness

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1369 --- 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-3699) Update protocol page on website to explain how KIP-35 should be used

[ https://issues.apache.org/jira/browse/KAFKA-3699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280247#comment-15280247 ] Ismael Juma commented on KAFKA-3699: Thanks [~singhashish]. > Update protocol page on

[GitHub] kafka pull request: MINOR: Improve handling of channel close excep...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1370 MINOR: Improve handling of channel close exception Propagate IOException in SslTransportLayer channel.close to be consistent with PlaintextTransportLayer, close authenticator on channel close

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

See

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

See Changes: [ismael] MINOR: Ensure that selection key is cancelled on close -- [...truncated 3286 lines...] kafka.integration.AutoOffsetResetTest > testResetToEarliestWhenOffsetTooHigh PASSED

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

See Changes: [ismael] MINOR: Documentation for Rack Awareness -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-4 (docker Ubuntu ubuntu4 ub

[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=15280293#comment-15280293 ] Grant Henke commented on KAFKA-3396: [~ecomar] Thanks for working on a patch! Feel fre

[jira] [Commented] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280295#comment-15280295 ] Grant Henke commented on KAFKA-3692: Linked KAFKA-1508 since this patch would likely f

[jira] [Assigned] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned KAFKA-3698: --- Assignee: Jiangjie Qin > Update website documentation when it comes to the message format > -

[jira] [Commented] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280310#comment-15280310 ] Jiangjie Qin commented on KAFKA-3698: - [~ijuma] Sure, just assigned it myself. > Upda

[jira] [Commented] (KAFKA-3692) Wildcards in External CLASSPATH may cause it not be included in the CLASSPATH

[ https://issues.apache.org/jira/browse/KAFKA-3692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280318#comment-15280318 ] Ismael Juma commented on KAFKA-3692: Good point [~granthenke]. That issue also mention

[jira] [Assigned] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-3697: -- Assignee: Vahid Hashemian > Clean-up website documentation when it comes to clients > -

[jira] [Created] (KAFKA-3702) SslTransportLayer.close() does not shutdown gracefully

Rajini Sivaram created KAFKA-3702: - Summary: SslTransportLayer.close() does not shutdown gracefully Key: KAFKA-3702 URL: https://issues.apache.org/jira/browse/KAFKA-3702 Project: Kafka Issue

[jira] [Commented] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280332#comment-15280332 ] Ismael Juma commented on KAFKA-3697: [~vahid], a quick note: I set the fix version as

[jira] [Created] (KAFKA-3703) PlaintextTransportLayer.close() doesn't complete outgoing writes

Rajini Sivaram created KAFKA-3703: - Summary: PlaintextTransportLayer.close() doesn't complete outgoing writes Key: KAFKA-3703 URL: https://issues.apache.org/jira/browse/KAFKA-3703 Project: Kafka

[jira] [Updated] (KAFKA-3283) Consider marking the new consumer as production-ready

[ https://issues.apache.org/jira/browse/KAFKA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3283: --- Description: Ideally, we would: * Remove the beta label * Filling any critical gaps in functionality

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

See

[jira] [Updated] (KAFKA-3689) ERROR Processor got uncaught exception. (kafka.network.Processor)

[ https://issues.apache.org/jira/browse/KAFKA-3689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3689: --- Fix Version/s: (was: 0.9.0.2) (was: 0.11.0.0) (was: 0

[jira] [Commented] (KAFKA-3693) Race condition between highwatermark-checkpoint thread and handleLeaderAndIsrRequest at broker start-up

[ https://issues.apache.org/jira/browse/KAFKA-3693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280411#comment-15280411 ] Maysam Yabandeh commented on KAFKA-3693: [~junrao] based on controller logs the fo

[jira] [Commented] (KAFKA-3685) Auto-generate ZooKeeper data structure wiki

[ https://issues.apache.org/jira/browse/KAFKA-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280421#comment-15280421 ] Grant Henke commented on KAFKA-3685: This would likely take some rework of the ZkUtils

Re: [DISCUSS] KIP-59 - Proposal for a kafka broker command - kafka-brokers.sh

Hello Jayesh, Thank you for the suggestion. I like the proposal and the new tool seems useful. Do you already have the tool available in a github repository? If you don't, then this would be a good place to start - there are many Kafka utilities in github repositories (Yahoo's Kafka Manager as a

[jira] [Commented] (KAFKA-3685) Auto-generate ZooKeeper data structure wiki

[ https://issues.apache.org/jira/browse/KAFKA-3685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280612#comment-15280612 ] Vahid Hashemian commented on KAFKA-3685: [~granthenke] Sure, I can take this on. I

Migrating Kafka from old VMs to new VMs in a different Cluster

Hello Everyone, We have Kafka brokers, Zookeepers and Mirror-makers running on old Virtual Machines. We need to migrate all of this to brand new VMs on a different DataCenter and bring down the old VMs. Is this possible? If so, please suggest a way to do it. Best, Abhinav

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280721#comment-15280721 ] Jiangjie Qin commented on KAFKA-3565: - [~junrao] [~guozhang] I think it makes sense to

[GitHub] kafka pull request: KAFKA-3690: Avoid to pass null to Unmodifiable...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1360 --- 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] [Resolved] (KAFKA-3690) Avoid passing null to UnmodifiableMap

[ https://issues.apache.org/jira/browse/KAFKA-3690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3690. -- Resolution: Fixed Fix Version/s: 0.10.1.0 Issue resolved by pull request

[jira] [Commented] (KAFKA-3690) Avoid passing null to UnmodifiableMap

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

[GitHub] kafka pull request: MINOR: Improve handling of channel close excep...

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

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

See

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280863#comment-15280863 ] Guozhang Wang commented on KAFKA-3565: -- Yes, that is a valid concern. Maybe we can ad

Jenkins build is back to normal : kafka-0.10.0-jdk7 #79

See

[jira] [Created] (KAFKA-3704) Use default block size in KafkaProducer

Guozhang Wang created KAFKA-3704: Summary: Use default block size in KafkaProducer Key: KAFKA-3704 URL: https://issues.apache.org/jira/browse/KAFKA-3704 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-3697) Clean-up website documentation when it comes to clients

[ https://issues.apache.org/jira/browse/KAFKA-3697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280894#comment-15280894 ] Vahid Hashemian commented on KAFKA-3697: [~ijuma] Sure, I'll wait for the blocker

[GitHub] kafka pull request: KAFKA-3565: Remove hard-coded block size in Ka...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1371 KAFKA-3565: Remove hard-coded block size in KafkaProducer You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K3565-remove-

[jira] [Created] (KAFKA-3705) Support non-key joining in KTable

Guozhang Wang created KAFKA-3705: Summary: Support non-key joining in KTable Key: KAFKA-3705 URL: https://issues.apache.org/jira/browse/KAFKA-3705 Project: Kafka Issue Type: Bug Com

[GitHub] kafka pull request: KAFKA-3565: Add documentation to warn user abo...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1372 KAFKA-3565: Add documentation to warn user about the potential messag… …e throughput drop due to the addition of timestamp field. You can merge this pull request into a Git repository by runni

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280933#comment-15280933 ] Gwen Shapira commented on KAFKA-3565: - 32K per partition sounds pretty minor to me. Y

[jira] [Commented] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280937#comment-15280937 ] Jiangjie Qin commented on KAFKA-3698: - [~ijuma] Is the message format section of 0.9 c

[GitHub] kafka pull request: KAFKA-3694: Ensure broker Zk deregistration pr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1365 --- 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] [Resolved] (KAFKA-3694) Transient system test failure ReplicationTest.test_replication_with_broker_failure.security_protocol

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

[jira] [Commented] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15280946#comment-15280946 ] Ismael Juma commented on KAFKA-3698: [~becket_qin], it seemed wrong to me when I looke

[GitHub] kafka pull request: KAFKA-3515: migrate json serde from connect to...

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

[GitHub] kafka pull request: KAFKA-3704: Remove hard-coded block size in Ka...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1371 --- 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] [Resolved] (KAFKA-3704) Use default block size in KafkaProducer

[ https://issues.apache.org/jira/browse/KAFKA-3704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3704. -- Resolution: Fixed Issue resolved by pull request 1371 [https://github.com/apache/kafka/pull/1371

[GitHub] kafka pull request: MINOR: Fix order of compression algorithms in ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/1373 MINOR: Fix order of compression algorithms in upgrade note You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka fix-producer-buffer-size-u

[GitHub] kafka pull request: KAFKA-3583: Add documentation for Connect stat...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1358 --- 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] [Resolved] (KAFKA-3583) Docs on pause/resume/restart APIs.

[ https://issues.apache.org/jira/browse/KAFKA-3583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3583. -- Resolution: Fixed Fix Version/s: 0.10.0.0 0.10.1.0 Iss

Avoid recreating reassign partition path in zk if it is already deleted

Hi I wondering if makes sense to remove {code} case nne: ZkNoNodeException => createPersistentPath(zkPath, jsonData) debug("Created path %s with %s for partition reassignment".format(zkPath, jsonData)) {code} from ZKUtils::updatePartitionReassignmentData, which ha

[GitHub] kafka pull request: MINOR: Fix order of compression algorithms in ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1373 --- 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] [Updated] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3698: --- Status: Open (was: Patch Available) > Update website documentation when it comes to the message forma

[jira] [Updated] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3698: --- Reviewer: Jun Rao (was: Ismael Juma) Status: Patch Available (was: Open) > Update website docu

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

See Changes: [ismael] KAFKA-3694; Ensure broker Zk deregistration prior to restart in -- [...truncated 1967 lines...] val producerConfig = new ProducerConfig(props)

[GitHub] kafka pull request: MINOR: Change type of StreamsConfig.BOOTSTRAP_...

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/1374 MINOR: Change type of StreamsConfig.BOOTSTRAP_SERVERS_CONFIG to List You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka KM

[GitHub] kafka pull request: KAFKA-3698: Update the message format section.

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/1375 KAFKA-3698: Update the message format section. You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-3698 Alternatively you c

[jira] [Updated] (KAFKA-3698) Update website documentation when it comes to the message format

[ https://issues.apache.org/jira/browse/KAFKA-3698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3698: Status: Patch Available (was: Open) > Update website documentation when it comes to the message for

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281192#comment-15281192 ] Jiangjie Qin commented on KAFKA-3565: - [~gwenshap] I am not sure if 32K is minor. Ty

[jira] [Commented] (KAFKA-3565) Producer's throughput lower with compressed data after KIP-31/32

[ https://issues.apache.org/jira/browse/KAFKA-3565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281213#comment-15281213 ] Gwen Shapira commented on KAFKA-3565: - This is consistent with my calculations, except

[jira] [Created] (KAFKA-3706) kafka-console-consumer.sh picks up old consumer by default

Arun Mahadevan created KAFKA-3706: - Summary: kafka-console-consumer.sh picks up old consumer by default Key: KAFKA-3706 URL: https://issues.apache.org/jira/browse/KAFKA-3706 Project: Kafka Is

RE: [DISCUSS] KIP-59 - Proposal for a kafka broker command - kafka-brokers.sh

Thanks Gwen - yes, I agree - let me work on it, make it available on github and then I guess we can go from there. Thanks, Jayesh -Original Message- From: Gwen Shapira [mailto:g...@confluent.io] Sent: Wednesday, May 11, 2016 12:26 PM To: dev@kafka.apache.org; Jayesh Thakrar Cc: Users

[jira] [Assigned] (KAFKA-3645) NPE in ConsumerGroupCommand and ConsumerOffsetChecker when running in a secure env

[ https://issues.apache.org/jira/browse/KAFKA-3645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan reassigned KAFKA-3645: - Assignee: Arun Mahadevan > NPE in ConsumerGroupCommand and ConsumerOffsetChecker when run

Re: Migrating Kafka from old VMs to new VMs in a different Cluster

Depends on your use case but I guess something like this: - Install al fresh on the new VM's - Start a mirror maker in the the new VM's to copy data from the old ones - Be sure it's working right - Shut down the old VM's and start using the new ones The last step is the trickiest and depends a lot

[GitHub] kafka pull request: KAFKA-3706: Make new consumer as default in ka...

GitHub user arunmahadevan opened a pull request: https://github.com/apache/kafka/pull/1376 KAFKA-3706: Make new consumer as default in kafka console consumer 1. Made new consumer the default in console consumer 2. Added --old-consumer option to choose old consumer You can merge