[GitHub] kafka pull request #2380: MINOR: replace remove() with delete() after 5.0.1 ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2380 --- 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-4634) Issue of one kafka brokers not listed in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Maharajan Shunmuga Sundaram updated KAFKA-4634: --- Environment: Zookeeper version: 3.4.6-1569965, built on 02/20/2014 09:

[jira] [Assigned] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

[ https://issues.apache.org/jira/browse/KAFKA-4617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhwani Katagade reassigned KAFKA-4617: -- Assignee: Dhwani Katagade > gradle-generated core eclipse project has incorrect source

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823180#comment-15823180 ] Alberto Forti commented on KAFKA-4629: -- Hi, You need at least two brokers to reprodu

[jira] [Commented] (KAFKA-4634) Issue of one kafka brokers not listed in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823181#comment-15823181 ] Maharajan Shunmuga Sundaram commented on KAFKA-4634: Here is the histo

[jira] [Commented] (KAFKA-4634) Issue of one kafka brokers not listed in zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-4634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823187#comment-15823187 ] Maharajan Shunmuga Sundaram commented on KAFKA-4634: I do see followin

[GitHub] kafka pull request #2382: KAFKA-4617: Generate core project with correct sou...

GitHub user dhwanikatagade opened a pull request: https://github.com/apache/kafka/pull/2382 KAFKA-4617: Generate core project with correct source folders. Generate core project with correct source folders. In addition set output folders same as command line build. Don't generate unn

[jira] [Commented] (KAFKA-4617) gradle-generated core eclipse project has incorrect source folder structure

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

[GitHub] kafka pull request #2324: KAFKA-4604: Fix gradle build to avoid generating u...

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

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

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

[jira] [Commented] (KAFKA-4629) Per topic MBeans leak

[ https://issues.apache.org/jira/browse/KAFKA-4629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823329#comment-15823329 ] huxi commented on KAFKA-4629: - [~alberto.fo...@natwestmarkets.com] Yes, multiple brokers DOES

[GitHub] kafka pull request #2383: MINOR: Some cleanups and additional testing for KI...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2383 MINOR: Some cleanups and additional testing for KIP-88 You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka minor-cleanup-kip-88 A

[jira] [Commented] (KAFKA-4577) NPE in ControllerChannelManager.scala::addUpdateMetadataRequestForBrokers

[ https://issues.apache.org/jira/browse/KAFKA-4577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823347#comment-15823347 ] huxi commented on KAFKA-4577: - I suspect the TopicDeletionManager instance in KafkaController

[GitHub] kafka pull request #2384: KAFKA-4622: Consumer should handle group authoriza...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2384 KAFKA-4622: Consumer should handle group authorization errors in offset fetch You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Commented] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

[ https://issues.apache.org/jira/browse/KAFKA-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823361#comment-15823361 ] Jason Gustafson commented on KAFKA-4622: One correction to the description: Topic

[jira] [Commented] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

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

[jira] [Assigned] (KAFKA-4450) Add missing 0.10.1.x upgrade tests and ensure ongoing compatibility checks

[ https://issues.apache.org/jira/browse/KAFKA-4450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava reassigned KAFKA-4450: Assignee: Ewen Cheslack-Postava > Add missing 0.10.1.x upgrade tests and en

[jira] [Resolved] (KAFKA-3992) InstanceAlreadyExistsException Error for Consumers Starting in Parallel

[ https://issues.apache.org/jira/browse/KAFKA-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-3992. -- Resolution: Not A Problem Assignee: Ewen Cheslack-Postava As [~omkreddy] p

[jira] [Updated] (KAFKA-4590) Add system test for SASL/SCRAM

[ https://issues.apache.org/jira/browse/KAFKA-4590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4590: - Priority: Blocker (was: Major) > Add system test for SASL/SCRAM > ---

[jira] [Commented] (KAFKA-4557) ConcurrentModificationException in KafkaProducer event loop

[ https://issues.apache.org/jira/browse/KAFKA-4557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823399#comment-15823399 ] huxi commented on KAFKA-4557: - [~scf37] Did you create your own Sender instances in the produc

[jira] [Updated] (KAFKA-3213) [CONNECT] It looks like we are not backing off properly when reconfiguring tasks

[ https://issues.apache.org/jira/browse/KAFKA-3213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3213: - Priority: Major (was: Critical) > [CONNECT] It looks like we are not backing off

[jira] [Updated] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3522: - Priority: Major (was: Critical) > Consider adding version information into rocksD

[jira] [Commented] (KAFKA-3522) Consider adding version information into rocksDB storage format

[ https://issues.apache.org/jira/browse/KAFKA-3522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823413#comment-15823413 ] Ewen Cheslack-Postava commented on KAFKA-3522: -- [~imandhan] There's a KIP pro

[jira] [Commented] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823415#comment-15823415 ] Ewen Cheslack-Postava commented on KAFKA-3190: -- [~becket_qin] Do you want to

[jira] [Commented] (KAFKA-2500) Expose fetch response high watermark in ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823420#comment-15823420 ] Ewen Cheslack-Postava commented on KAFKA-2500: -- [~hachikuji] [~rmetzger] [~wi

[jira] [Updated] (KAFKA-1694) KIP-4: Command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1694: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > KIP-4: Command li

[jira] [Updated] (KAFKA-1313) Support adding replicas to existing topic partitions via kafka-topics tool without manually setting broker assignments

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-1313: - Assignee: (was: Geoff Anderson) Priority: Major (was: Critical)

[jira] [Commented] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823429#comment-15823429 ] Ewen Cheslack-Postava commented on KAFKA-4631: -- Would this be a constant time

[jira] [Updated] (KAFKA-4631) Refresh consumer metadata more frequently for unknown subscribed topics

[ https://issues.apache.org/jira/browse/KAFKA-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4631: - Priority: Minor (was: Major) > Refresh consumer metadata more frequently for unkn

[jira] [Commented] (KAFKA-4630) Implement RecordTooLargeException when communicating with pre-KIP-74 brokers

[ https://issues.apache.org/jira/browse/KAFKA-4630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823431#comment-15823431 ] Ewen Cheslack-Postava commented on KAFKA-4630: -- [~cmccabe] Should this be a b

[jira] [Commented] (KAFKA-4614) Long GC pause harming broker performance which is caused by mmap objects created for OffsetIndex

[ https://issues.apache.org/jira/browse/KAFKA-4614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823442#comment-15823442 ] Ewen Cheslack-Postava commented on KAFKA-4614: -- [~ijuma] Seems like you start

[jira] [Updated] (KAFKA-4602) KIP-72 Allow putting a bound on memory consumed by Incoming requests

[ https://issues.apache.org/jira/browse/KAFKA-4602?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4602: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 [~radai] I'm going

[jira] [Commented] (KAFKA-4596) KIP-73 rebalance throttling breaks on plans for specific partitions

[ https://issues.apache.org/jira/browse/KAFKA-4596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823463#comment-15823463 ] Ewen Cheslack-Postava commented on KAFKA-4596: -- [~ijuma] [~tcrayford-heroku]

[jira] [Updated] (KAFKA-4589) Add documentation for SASL/SCRAM

[ https://issues.apache.org/jira/browse/KAFKA-4589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4589: - Priority: Blocker (was: Major) > Add documentation for SASL/SCRAM > -

[jira] [Updated] (KAFKA-4580) Change one SASL system test to use new JAAS config property

[ https://issues.apache.org/jira/browse/KAFKA-4580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4580: - Priority: Blocker (was: Major) [~rsivaram] Moving to blocker since it'd be ideal

[jira] [Commented] (KAFKA-4563) State transitions error PARTITIONS_REVOKED to NOT_RUNNING

[ https://issues.apache.org/jira/browse/KAFKA-4563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823473#comment-15823473 ] Ewen Cheslack-Postava commented on KAFKA-4563: -- [~enothereska] https://github

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4547: - Affects Version/s: 0.10.0.2 > Consumer.position returns incorrect results for Kafk

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4547: - Affects Version/s: 0.10.1.1 > Consumer.position returns incorrect results for Kafk

[jira] [Updated] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

[ https://issues.apache.org/jira/browse/KAFKA-4547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4547: - Priority: Blocker (was: Major) Bumping to blocker -- this is pretty basic functio

[jira] [Updated] (KAFKA-4501) Support Java 9

[ https://issues.apache.org/jira/browse/KAFKA-4501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4501: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 Moving to 0.10.3.0

[jira] [Commented] (KAFKA-4421) Update release process so that Scala 2.12 artifacts are published

[ https://issues.apache.org/jira/browse/KAFKA-4421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823513#comment-15823513 ] Ewen Cheslack-Postava commented on KAFKA-4421: -- [~ijuma] A) should this be se

[jira] [Commented] (KAFKA-4401) Change the KafkaServerTestHarness and IntegrationTestHarness from trait to abstract class.

[ https://issues.apache.org/jira/browse/KAFKA-4401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823518#comment-15823518 ] Ewen Cheslack-Postava commented on KAFKA-4401: -- Could we make incremental pro

[jira] [Updated] (KAFKA-4363) Add document for dynamic JAAS configuration property sasl.jaas.config

[ https://issues.apache.org/jira/browse/KAFKA-4363?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4363: - Priority: Blocker (was: Major) > Add document for dynamic JAAS configuration prop

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

I updated KIP-110 with JMH-measured benchmark results. Please have a review when you are free. (The overall result is not different yet.) Regards, Dongjin +1. Could anyone assign KAFKA-4514 to me? On Thu, Jan 12, 2017 at 11:39 AM, Dongjin Lee wrote: > Okay, I will have a try. > Thanks Ewen for

[jira] [Updated] (KAFKA-4292) KIP-86: Configurable SASL callback handlers

[ https://issues.apache.org/jira/browse/KAFKA-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4292: - Summary: KIP-86: Configurable SASL callback handlers (was: Configurable SASL call

[jira] [Updated] (KAFKA-4292) KIP-86: Configurable SASL callback handlers

[ https://issues.apache.org/jira/browse/KAFKA-4292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4292: - Fix Version/s: (was: 0.10.2.0) Moving out of a target fixVersion -- KIP-86 has

[jira] [Commented] (KAFKA-4184) Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle

[ https://issues.apache.org/jira/browse/KAFKA-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823548#comment-15823548 ] Ewen Cheslack-Postava commented on KAFKA-4184: -- Are there more recent cases o

[jira] [Updated] (KAFKA-4182) Move the change logger our of RocksDB stores

[ https://issues.apache.org/jira/browse/KAFKA-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4182: - Fix Version/s: (was: 0.10.2.0) The fixVersion has been set but there is no ass

[jira] [Commented] (KAFKA-4178) Replication Throttling: Consolidate Rate Classes

[ https://issues.apache.org/jira/browse/KAFKA-4178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823551#comment-15823551 ] Ewen Cheslack-Postava commented on KAFKA-4178: -- [~benstopford] This will now

[jira] [Commented] (KAFKA-4084) automated leader rebalance causes replication downtime for clusters with too many partitions

[ https://issues.apache.org/jira/browse/KAFKA-4084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823557#comment-15823557 ] Ewen Cheslack-Postava commented on KAFKA-4084: -- [~tcrayford-heroku] Answer to

[jira] [Commented] (KAFKA-4005) Add per topic compression ratio in broker and consumer.

[ https://issues.apache.org/jira/browse/KAFKA-4005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823556#comment-15823556 ] Ewen Cheslack-Postava commented on KAFKA-4005: -- I agree this would be useful,

[jira] [Updated] (KAFKA-4221) KafkaConsumer Fetcher can send ListOffsets requests in parallel when initializing position

[ https://issues.apache.org/jira/browse/KAFKA-4221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4221: - Fix Version/s: (was: 0.10.2.0) This is a nice improvement, but not strictly re

[jira] [Updated] (KAFKA-3959) __consumer_offsets wrong number of replicas at startup

[ https://issues.apache.org/jira/browse/KAFKA-3959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3959: - Affects Version/s: 0.10.1.2 0.10.0.2

[jira] [Commented] (KAFKA-3190) KafkaProducer should not invoke callback in send()

[ https://issues.apache.org/jira/browse/KAFKA-3190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15823583#comment-15823583 ] Jiangjie Qin commented on KAFKA-3190: - [~ewencp] This remains an issue and confuses so