[jira] [Commented] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15498293#comment-15498293 ] Ben Stopford commented on KAFKA-3438: - Sorry, missed your original comment. Go for it.

ProducerRecord/Consumer MetaData/Headers

Hi All, First of all apologies if this has been previously discussed I have just joined the mail list (I cannot find a JIRA or KIP related nor via good old google search) In our company we are looking to replace some of our more traditional message flows with Kafka. One thing we have found la

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

See Changes: [jason] KAFKA-4173; SchemaProjector should successfully project missing Struct -- [...truncated 5517 lines...] kafka.api.PlaintextProducerSendTest > testSendToPartition STARTED kaf

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

See Changes: [jason] KAFKA-4173; SchemaProjector should successfully project missing Struct -- [...truncated 11003 lines...] org.apache.kafka.common.record.RecordTest > testFields[172] PASSED or

[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=15497797#comment-15497797 ] Ismael Juma commented on KAFKA-3396: Marking this as "Critical" so that we can make su

[jira] [Updated] (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 ] Ismael Juma updated KAFKA-3396: --- Priority: Critical (was: Major) > Unauthorized topics are returned to the user >

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

See Changes: [jason] KAFKA-4183; Corrected Kafka Connect's JSON Converter to properly convert -- [...truncated 1940 lines...] kafka.api.SslConsumerTest > testCoordinatorFailover STARTED kafka.

[UPDATE] 0.10.1 Release Progress

Hi All, Thanks everyone for the hard work! Here's an update on the remaining KIPs that we are hoping to include: KIP-78 (clusterId): Review is basically complete. Assuming no problems emerge, Ismael is planning to merge today. KIP-74 (max fetch size): Review is nearing completion, just a few mino

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

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

[GitHub] kafka pull request #1872: KAFKA-4183: centralize checking for optional and d...

GitHub user shikhar opened a pull request: https://github.com/apache/kafka/pull/1872 KAFKA-4183: centralize checking for optional and default values to avoid bugs Cleaner to just check once for optional & default value from the `convertToConnect()` function. It also helps

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497694#comment-15497694 ] Randall Hauch commented on KAFKA-4183: -- [~shikhar], that'd be great. Note that I crea

[jira] [Commented] (KAFKA-4173) SchemaProjector should successfully project when source schema field is missing and target schema field is optional

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

[jira] [Resolved] (KAFKA-4173) SchemaProjector should successfully project when source schema field is missing and target schema field is optional

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

[GitHub] kafka pull request #1865: KAFKA-4173: SchemaProjector should successfully pr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1865 --- 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] [Reopened] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan reopened KAFKA-4183: Assignee: Shikhar Bhushan (was: Ewen Cheslack-Postava) [~rhauch] Reopening this, I notice

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

See Changes: [jason] KAFKA-4183; Corrected Kafka Connect's JSON Converter to properly convert -- [...truncated 3392 lines...] kafka.integration.PrimitiveApiTest > testMultiProduce STARTED kafka.

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497626#comment-15497626 ] Randall Hauch commented on KAFKA-4183: -- [~hachikuji], thanks. I've created a [pull r

[jira] [Commented] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497628#comment-15497628 ] Jason Gustafson commented on KAFKA-4133: [~mimaison] Thanks for writing the KIP! I

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

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

[GitHub] kafka pull request #1871: KAFKA-4183 Corrected Kafka Connect's JSON Converte...

GitHub user rhauch opened a pull request: https://github.com/apache/kafka/pull/1871 KAFKA-4183 Corrected Kafka Connect's JSON Converter to properly convert from null to logical values The `JsonConverter` class has `LogicalTypeConverter` implementations for Date, Time, Timestamp, an

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497578#comment-15497578 ] Jason Gustafson commented on KAFKA-4183: [~rhauch] Good question. I'm not sure I h

[jira] [Created] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey

Jason Gustafson created KAFKA-4186: -- Summary: Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey Key: KAFKA-4186 URL: https://issues.apache.org/jira/browse/KAFKA-4186 Project: Ka

[jira] [Updated] (KAFKA-4186) Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey

[ https://issues.apache.org/jira/browse/KAFKA-4186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4186: --- Component/s: streams > Transient failure in KStreamAggregationIntegrationTest.shouldGroupByKey

[jira] [Commented] (KAFKA-3906) Connect logical types do not support nulls.

[ https://issues.apache.org/jira/browse/KAFKA-3906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497533#comment-15497533 ] Shikhar Bhushan commented on KAFKA-3906: [~jcustenborder] did this come up in the

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497530#comment-15497530 ] Randall Hauch commented on KAFKA-4183: -- [~hachikuji], will there be a 0.10.0.2? If so

[jira] [Updated] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4183: --- Resolution: Fixed Fix Version/s: 0.10.1.0 Status: Resolved (was: Patch Avail

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

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

[GitHub] kafka pull request #1867: KAFKA-4183 Corrected Kafka Connect's JSON Converte...

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

[GitHub] kafka pull request #1868: MINOR: Improve output format of `kafka_reassign_pa...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/1868 MINOR: Improve output format of `kafka_reassign_partitions.sh` tool The current output for the `--generate` option looks like this ``` Current partition replica assignment {

[GitHub] kafka pull request #1868: MINOR: Improve output format of `kafka_reassign_pa...

Github user vahidhashemian closed the pull request at: https://github.com/apache/kafka/pull/1868 --- 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-4185) Abstract out password verifier in SaslServer as an injectable dependency

[ https://issues.apache.org/jira/browse/KAFKA-4185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497494#comment-15497494 ] Piyush Vijay commented on KAFKA-4185: - [~junrao], [~gwenshap], [~ijuma] Any thoughts?

No-deps Kafka Java client?

Hey Kafkas, Would it make sense to offer a no-deps Kafka client (with third-party packages like com.example.xxx relocated to a package like org.apache.kafka.relocated.com.example.xxx)? cglib is one example of a project that does this, in the form of cglib-nodep: http://search.maven.org/#search%

[jira] [Commented] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

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

[GitHub] kafka pull request #1870: [KAFKA-4185] Abstract out password verifier in Sas...

GitHub user piyushvijay opened a pull request: https://github.com/apache/kafka/pull/1870 [KAFKA-4185] Abstract out password verifier in SaslServer as an injec… …table dependency You can merge this pull request into a Git repository by running: $ git pull https://github.com/

Re: [VOTE] 0.10.1 Release Plan

Hi All, Looks like this vote has passed with 8 binding and 4 non-binding votes. I'll send a progress update this afternoon as we race for the Monday feature freeze. Thanks, Jason On Wed, Sep 14, 2016 at 11:08 PM, Neha Narkhede wrote: > +1 (binding) > > On Tue, Sep 13, 2016 at 6:58 PM Becket Qi

[jira] [Created] (KAFKA-4185) Abstract out password verifier in SaslServer as an injectable dependency

Piyush Vijay created KAFKA-4185: --- Summary: Abstract out password verifier in SaslServer as an injectable dependency Key: KAFKA-4185 URL: https://issues.apache.org/jira/browse/KAFKA-4185 Project: Kafka

[jira] [Resolved] (KAFKA-3778) Avoiding using range queries of RocksDBWindowStore on KStream windowed aggregations

[ https://issues.apache.org/jira/browse/KAFKA-3778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-3778. - Resolution: Fixed > Avoiding using range queries of RocksDBWindowStore on KStream windowed > aggr

[jira] [Resolved] (KAFKA-3780) Add new config cache.max.bytes.buffering to the streams configuration

[ https://issues.apache.org/jira/browse/KAFKA-3780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-3780. - Resolution: Fixed > Add new config cache.max.bytes.buffering to the streams configuration > --

[jira] [Resolved] (KAFKA-4069) Forward records in context of cache flushing/eviction

[ https://issues.apache.org/jira/browse/KAFKA-4069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-4069. - Resolution: Fixed > Forward records in context of cache flushing/eviction > --

[jira] [Resolved] (KAFKA-4167) Add cache metrics

[ https://issues.apache.org/jira/browse/KAFKA-4167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-4167. - Resolution: Fixed > Add cache metrics > - > > Key: KAFKA-4167 >

[jira] [Resolved] (KAFKA-3974) LRU cache should store bytes/object and not records

[ https://issues.apache.org/jira/browse/KAFKA-3974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-3974. - Resolution: Fixed > LRU cache should store bytes/object and not records >

[jira] [Resolved] (KAFKA-3777) Extract the existing LRU cache out of RocksDBStore

[ https://issues.apache.org/jira/browse/KAFKA-3777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eno Thereska resolved KAFKA-3777. - Resolution: Fixed > Extract the existing LRU cache out of RocksDBStore > -

[jira] [Assigned] (KAFKA-3438) Rack Aware Replica Reassignment should warn of overloaded brokers

[ https://issues.apache.org/jira/browse/KAFKA-3438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-3438: -- Assignee: Vahid Hashemian > Rack Aware Replica Reassignment should warn of overloaded b

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

Jason Gustafson created KAFKA-4184: -- Summary: Test failure in ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle Key: KAFKA-4184 URL: https://issues.apache.org/jira/browse/KAFKA-4184

[GitHub] kafka pull request #1869: HOTFIX: changed quickstart donwload from 0.10.0.0 ...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/1869 HOTFIX: changed quickstart donwload from 0.10.0.0 to 0.10.0.1 You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka hotfix-doc Alternativel

[GitHub] kafka pull request #1868: MINOR: Improve output format of `kafka_reassign_pa...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/1868 MINOR: Improve output format of `kafka_reassign_partitions.sh` tool The current output for the `--generate` option looks like this ``` Current partition replica assignment {"v

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

See Changes: [wangguoz] KAFKA-3776: Unify store and downstream caching in streams -- [...truncated 12991 lines...] org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfoTest >

[jira] [Updated] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-4183: - Status: Patch Available (was: Open) Added a [pull request|https://github.com/apache/kafka/pull/18

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

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

[GitHub] kafka pull request #1867: KAFKA-4183 Corrected Kafka Connect's JSON Converte...

GitHub user rhauch opened a pull request: https://github.com/apache/kafka/pull/1867 KAFKA-4183 Corrected Kafka Connect's JSON Converter to properly convert from null to logical values The `JsonConverter` class has `LogicalTypeConverter` implementations for Date, Time, Timestamp, an

[GitHub] kafka pull request #1866: MINOR: Add test cases for delays in consumer rebal...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/1866 MINOR: Add test cases for delays in consumer rebalance listener You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka rebalance-dela

[jira] [Commented] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

[ https://issues.apache.org/jira/browse/KAFKA-4183?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15497073#comment-15497073 ] Randall Hauch commented on KAFKA-4183: -- I should be able to provide a pull request to

[jira] [Created] (KAFKA-4183) Logical converters in JsonConverter don't properly handle null values

Randall Hauch created KAFKA-4183: Summary: Logical converters in JsonConverter don't properly handle null values Key: KAFKA-4183 URL: https://issues.apache.org/jira/browse/KAFKA-4183 Project: Kafka

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

See Changes: [wangguoz] KAFKA-3776: Unify store and downstream caching in streams -- [...truncated 3385 lines...] kafka.integration.PrimitiveApiTest > testMultiProduce STARTED kafka.integration

[jira] [Commented] (KAFKA-4173) SchemaProjector should successfully project when source schema field is missing and target schema field is optional

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

[GitHub] kafka pull request #1865: KAFKA-4173: SchemaProjector should successfully pr...

GitHub user shikhar opened a pull request: https://github.com/apache/kafka/pull/1865 KAFKA-4173: SchemaProjector should successfully project missing Struct field when target field is optional You can merge this pull request into a Git repository by running: $ git pull https:/

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

Damian Guy created KAFKA-4182: - Summary: Move the change logger our of RocksDB stores Key: KAFKA-4182 URL: https://issues.apache.org/jira/browse/KAFKA-4182 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-4161) Decouple flush and offset commits

[ https://issues.apache.org/jira/browse/KAFKA-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shikhar Bhushan updated KAFKA-4161: --- Summary: Decouple flush and offset commits (was: Allow connectors to request flush via the co

[jira] [Commented] (KAFKA-4161) Allow connectors to request flush via the context

[ https://issues.apache.org/jira/browse/KAFKA-4161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496820#comment-15496820 ] Shikhar Bhushan commented on KAFKA-4161: We could also implement KAFKA-3462 here b

[jira] [Commented] (KAFKA-3776) Unify store and downstream caching in streams

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

[GitHub] kafka pull request #1752: KAFKA-3776: Unify store and downstream caching in ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1752 --- 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-3776) Unify store and downstream caching in streams

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

[jira] [Commented] (KAFKA-4133) Provide a configuration to control consumer max in-flight fetches

[ https://issues.apache.org/jira/browse/KAFKA-4133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496789#comment-15496789 ] Mickael Maison commented on KAFKA-4133: --- [~hachikuji] I've created KIP-80: https://

[jira] [Commented] (KAFKA-4181) Processors punctuate() methods call multiple times

[ https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496608#comment-15496608 ] Matthias J. Sax commented on KAFKA-4181: See also http://stackoverflow.com/a/39258

[jira] [Commented] (KAFKA-4181) Processors punctuate() methods call multiple times

[ https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496575#comment-15496575 ] Eno Thereska commented on KAFKA-4181: - Thanks for reporting this. Currently, this is i

[GitHub] kafka pull request #1864: Kafka-4177: Remove ThrottledReplicationRateLimit f...

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/1864 Kafka-4177: Remove ThrottledReplicationRateLimit from Server Config This small PR pulls ThrottledReplicationRateLimit out of KafkaConfig and puts it in a class that defines Dynamic Configs. Cli

[jira] [Commented] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496554#comment-15496554 ] Vahid Hashemian commented on KAFKA-2985: Perhaps you are running into [this issue

[jira] [Assigned] (KAFKA-4177) Replication Throttling: Remove ThrottledReplicationRateLimit from Server Config

[ https://issues.apache.org/jira/browse/KAFKA-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford reassigned KAFKA-4177: --- Assignee: Ben Stopford > Replication Throttling: Remove ThrottledReplicationRateLimit from Se

[jira] [Work started] (KAFKA-4177) Replication Throttling: Remove ThrottledReplicationRateLimit from Server Config

[ https://issues.apache.org/jira/browse/KAFKA-4177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4177 started by Ben Stopford. --- > Replication Throttling: Remove ThrottledReplicationRateLimit from Server > Confi

[jira] [Updated] (KAFKA-4181) Processors punctuate() methods call multiple times

[ https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Clinton updated KAFKA-4181: - Description: I'm seeing odd behaviour whereby a Processor's punctuate(..) method is not invoked b

[jira] [Updated] (KAFKA-4181) Processors punctuate() methods call multiple times

[ https://issues.apache.org/jira/browse/KAFKA-4181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] James Clinton updated KAFKA-4181: - Description: I'm seeing odd behaviour whereby a Processor's punctuate(..) method is not invoked b

[jira] [Created] (KAFKA-4181) Processors punctuate() methods call multiple times

James Clinton created KAFKA-4181: Summary: Processors punctuate() methods call multiple times Key: KAFKA-4181 URL: https://issues.apache.org/jira/browse/KAFKA-4181 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-4180) Shared authentification with multiple actives Kafka producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15496095#comment-15496095 ] Mickael Maison commented on KAFKA-4180: --- Hi Guillaume, You can achieve that by havi

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

See Changes: [junrao] KAFKA-1464; Add a throttling option to the Kafka replication -- [...truncated 11024 lines...] org.apache.kafka.common.record.RecordTest > testFields[172] PASSED org.apache.

[jira] [Created] (KAFKA-4180) Shared authentification with multiple actives Kafka producers/consumers

Guillaume Grossetie created KAFKA-4180: -- Summary: Shared authentification with multiple actives Kafka producers/consumers Key: KAFKA-4180 URL: https://issues.apache.org/jira/browse/KAFKA-4180 Pro

[jira] [Updated] (KAFKA-4179) Replication Throttling: Add Usability Metrics PartitionBytesInRate & SumReplicaLag

[ https://issues.apache.org/jira/browse/KAFKA-4179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford updated KAFKA-4179: Affects Version/s: 0.10.1.0 Description: Add two new metrics to Kafka PartitionBytesInRa

[jira] [Created] (KAFKA-4179) Replication Throttling: Add Usability Metrics PartitionBytesInRate & SumReplicaLag

Ben Stopford created KAFKA-4179: --- Summary: Replication Throttling: Add Usability Metrics PartitionBytesInRate & SumReplicaLag Key: KAFKA-4179 URL: https://issues.apache.org/jira/browse/KAFKA-4179 Projec

[jira] [Updated] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group

[ https://issues.apache.org/jira/browse/KAFKA-4176?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Marek Svitok updated KAFKA-4176: Description: I have 3 nodes working in the same group. I started them one after the other. As I can

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

Ben Stopford created KAFKA-4178: --- Summary: Replication Throttling: Consolidate Rate Classes Key: KAFKA-4178 URL: https://issues.apache.org/jira/browse/KAFKA-4178 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-4177) Replication Throttling: Remove ThrottledReplicationRateLimit from Server Config

Ben Stopford created KAFKA-4177: --- Summary: Replication Throttling: Remove ThrottledReplicationRateLimit from Server Config Key: KAFKA-4177 URL: https://issues.apache.org/jira/browse/KAFKA-4177 Project:

[jira] [Created] (KAFKA-4176) Node stopped receiving heartbeat responses once another node started within the same group

Marek Svitok created KAFKA-4176: --- Summary: Node stopped receiving heartbeat responses once another node started within the same group Key: KAFKA-4176 URL: https://issues.apache.org/jira/browse/KAFKA-4176

[jira] [Commented] (KAFKA-2985) Consumer group stuck in rebalancing state

[ https://issues.apache.org/jira/browse/KAFKA-2985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15495651#comment-15495651 ] Rajneesh Mitharwal commented on KAFKA-2985: --- Anyone found solution to fix this i