[jira] [Commented] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

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

[GitHub] kafka pull request: KAFKA-3003 Update the replica.highWatermark co...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/688 KAFKA-3003 Update the replica.highWatermark correctly You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-3003 Alternatively

[jira] [Commented] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

[ https://issues.apache.org/jira/browse/KAFKA-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15061582#comment-15061582 ] Dong Lin commented on KAFKA-3003: - Great catch! > The fetch.wait.max.ms is not honored wh

[jira] [Updated] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

[ https://issues.apache.org/jira/browse/KAFKA-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3003: Fix Version/s: 0.9.0.1 > The fetch.wait.max.ms is not honored when new log segment rolled for low >

[jira] [Updated] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

[ https://issues.apache.org/jira/browse/KAFKA-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3003: Affects Version/s: 0.9.0.0 > The fetch.wait.max.ms is not honored when new log segment rolled for lo

[jira] [Updated] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

[ https://issues.apache.org/jira/browse/KAFKA-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-3003: Component/s: core > The fetch.wait.max.ms is not honored when new log segment rolled for low > volu

[jira] [Created] (KAFKA-3003) The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics.

Jiangjie Qin created KAFKA-3003: --- Summary: The fetch.wait.max.ms is not honored when new log segment rolled for low volume topics. Key: KAFKA-3003 URL: https://issues.apache.org/jira/browse/KAFKA-3003 P

[jira] [Assigned] (KAFKA-2375) Implement elasticsearch Copycat sink connector

[ https://issues.apache.org/jira/browse/KAFKA-2375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-2375: - Assignee: Liquan Pei > Implement elasticsearch Copycat sink connector > -

[jira] [Updated] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

[ https://issues.apache.org/jira/browse/KAFKA-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2422: Reviewer: Ewen Cheslack-Postava > Allow copycat connector plugins to be aliased to simpler names > -

[jira] [Assigned] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

[ https://issues.apache.org/jira/browse/KAFKA-2422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira reassigned KAFKA-2422: --- Assignee: Gwen Shapira (was: Ewen Cheslack-Postava) > Allow copycat connector plugins to be

[jira] [Commented] (KAFKA-2422) Allow copycat connector plugins to be aliased to simpler names

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

[GitHub] kafka pull request: KAFKA-2422: Allow copycat connector plugins to...

GitHub user gwenshap opened a pull request: https://github.com/apache/kafka/pull/687 KAFKA-2422: Allow copycat connector plugins to be aliased to simpler … …names You can merge this pull request into a Git repository by running: $ git pull https://github.com/gwenshap/kafka

[jira] [Commented] (KAFKA-2988) Change default value of log.cleaner.enable

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

[jira] [Updated] (KAFKA-2988) Change default configuration of the log cleaner

[ https://issues.apache.org/jira/browse/KAFKA-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2988: --- Summary: Change default configuration of the log cleaner (was: Change default value of log.cleaner.en

[GitHub] kafka pull request: KAFKA-2988: Change default configuration of th...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/686 KAFKA-2988: Change default configuration of the log cleaner You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka compaction Alter

[GitHub] kafka pull request: KAFKA-3002: Make available to specify hostname...

GitHub user sasakitoa opened a pull request: https://github.com/apache/kafka/pull/685 KAFKA-3002: Make available to specify hostname with Uppercase at broker list Make available to specify hostname with Uppercase at broker list You can merge this pull request into a Git repository b

[jira] [Commented] (KAFKA-3002) Make available to specify hostname with Uppercase at broker list

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

[jira] [Created] (KAFKA-3002) Make available to specify hostname with Uppercase at broker list

Sasaki Toru created KAFKA-3002: -- Summary: Make available to specify hostname with Uppercase at broker list Key: KAFKA-3002 URL: https://issues.apache.org/jira/browse/KAFKA-3002 Project: Kafka I

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

See Changes: [wangguoz] KAFKA-2984: KTable should send old values when required -- [...truncated 476 lines...] kafka.admin.AddPartitionsTest > testTopicDoesNotExist PASSED kafka.admin.AddPartiti

[jira] [Commented] (KAFKA-3000) __consumer_offsets topic grows indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15061168#comment-15061168 ] Maxim Vladimirskiy commented on KAFKA-3000: --- After I set log.cleaner.enable=true

[jira] [Resolved] (KAFKA-3000) __consumer_offsets topic grows indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-3000. Resolution: Not A Problem Assignee: Grant Henke > __consumer_offsets topic grows indefinitely

[jira] [Commented] (KAFKA-3000) __consumer_offsets topic grows indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15061154#comment-15061154 ] Grant Henke commented on KAFKA-3000: [~horkhe] Glad to hear that was it. I will resolv

Re: Consumer Offsets Compaction

I am considering changing these defaults in KAFKA-2988: log.cleaner.enable=true (was false) log.cleaner.dedupe.buffer.size=128MiB (was 500MiB) log.cleaner.delete.retention.ms=7 Days (was 1 day) Thoughts on those values? Should I add logic to make sure we scale down the buffer size instead of cau

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

See Changes: [wangguoz] KAFKA-2984: KTable should send old values when required -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H11 (Ubuntu ubun

[jira] [Commented] (KAFKA-2984) KTable should send old values along with new values to downstreams

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

[jira] [Resolved] (KAFKA-2984) KTable should send old values along with new values to downstreams

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

[GitHub] kafka pull request: KAFKA-2984: ktable sends old values when requi...

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

[jira] [Commented] (KAFKA-3000) __consumer_offsets topic grows indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15061133#comment-15061133 ] Maxim Vladimirskiy commented on KAFKA-3000: --- It was set to the default value `fa

[jira] [Created] (KAFKA-3001) Transient Failure in kafka.api.SaslPlaintextConsumerTest

Guozhang Wang created KAFKA-3001: Summary: Transient Failure in kafka.api.SaslPlaintextConsumerTest Key: KAFKA-3001 URL: https://issues.apache.org/jira/browse/KAFKA-3001 Project: Kafka Issue

[jira] [Commented] (KAFKA-3000) __consumer_offsets topic grows indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-3000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15061105#comment-15061105 ] Grant Henke commented on KAFKA-3000: Do you have log.cleaner.enable=true configured on

[jira] [Created] (KAFKA-3000) __consumer_offsets topic grows indefinitely

Maxim Vladimirskiy created KAFKA-3000: - Summary: __consumer_offsets topic grows indefinitely Key: KAFKA-3000 URL: https://issues.apache.org/jira/browse/KAFKA-3000 Project: Kafka Issue Typ

[GitHub] kafka pull request: KAFKA 2578 Client Metadata internal state shou...

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

[jira] [Commented] (KAFKA-2049) Add thread that detects JVM pauses

[ https://issues.apache.org/jira/browse/KAFKA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060729#comment-15060729 ] Ismael Juma commented on KAFKA-2049: I was wondering the same thing. The only thing I

[jira] [Commented] (KAFKA-2542) Reuse Throttler code

[ https://issues.apache.org/jira/browse/KAFKA-2542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060655#comment-15060655 ] Ted Malaska commented on KAFKA-2542: Hey Geoff, Are you still working on this one. I

[jira] [Resolved] (KAFKA-2712) Reassignment Partition Tool Issue

[ https://issues.apache.org/jira/browse/KAFKA-2712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2712. - Resolution: Won't Fix Not enough details to fix the issue. > Reassignment Partition Tool Issue >

[jira] [Resolved] (KAFKA-2049) Add thread that detects JVM pauses

[ https://issues.apache.org/jira/browse/KAFKA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2049. - Resolution: Won't Fix We have a GC log > Add thread that detects JVM pauses > ---

[jira] [Commented] (KAFKA-2049) Add thread that detects JVM pauses

[ https://issues.apache.org/jira/browse/KAFKA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060632#comment-15060632 ] Gwen Shapira commented on KAFKA-2049: - If you don't see a need for this either, yes, l

Re: [DISCUSS] KIP-36 - Rack aware replica assignment

Hi Jun, The reason that TopicMetadataResponse is not included in the KIP is that it currently is not version aware . So we need to introduce version to it in order to make sure backward compatibility. It seems to me a big change. Do we want to couple it with this KIP? Do we need to further discuss

[jira] [Commented] (KAFKA-2049) Add thread that detects JVM pauses

[ https://issues.apache.org/jira/browse/KAFKA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060626#comment-15060626 ] Ted Malaska commented on KAFKA-2049: So should we close it out then? > Add thread tha

[jira] [Commented] (KAFKA-2049) Add thread that detects JVM pauses

[ https://issues.apache.org/jira/browse/KAFKA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060623#comment-15060623 ] Gwen Shapira commented on KAFKA-2049: - It is embarrassing, since I created this ticket

[jira] [Created] (KAFKA-2999) Errors enum should be a 1 to 1 mapping of error codes and exceptions

Grant Henke created KAFKA-2999: -- Summary: Errors enum should be a 1 to 1 mapping of error codes and exceptions Key: KAFKA-2999 URL: https://issues.apache.org/jira/browse/KAFKA-2999 Project: Kafka

[jira] [Commented] (KAFKA-2049) Add thread that detects JVM pauses

[ https://issues.apache.org/jira/browse/KAFKA-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060440#comment-15060440 ] Ted Malaska commented on KAFKA-2049: Hey Gwen, Do you mind if I try this one? Thanks

[GitHub] kafka pull request: KAFKA-2929: Migrate duplicate error mapping fu...

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

[jira] [Commented] (KAFKA-2929) Migrate server side error mapping functionality

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

[GitHub] kafka pull request: KAFKA-2929: Migrate duplicate error mapping fu...

GitHub user granthenke reopened a pull request: https://github.com/apache/kafka/pull/616 KAFKA-2929: Migrate duplicate error mapping functionality Deprecates ErrorMapping.scala in core in favor or Errors.java in common. Duplicated exceptions in core are deprecated as well, to en

[jira] [Commented] (KAFKA-2929) Migrate server side error mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060416#comment-15060416 ] ASF GitHub Bot commented on KAFKA-2929: --- GitHub user granthenke reopened a pull requ

[jira] [Commented] (KAFKA-2998) New Consumer should not retry indefinitely if no broker is available

[ https://issues.apache.org/jira/browse/KAFKA-2998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060360#comment-15060360 ] Ismael Juma commented on KAFKA-2998: Thanks for the report. Is this a duplicate of KAF

[jira] [Created] (KAFKA-2998) New Consumer should not retry indefinitely if no broker is available

Florian Hussonnois created KAFKA-2998: - Summary: New Consumer should not retry indefinitely if no broker is available Key: KAFKA-2998 URL: https://issues.apache.org/jira/browse/KAFKA-2998 Project:

[jira] [Updated] (KAFKA-2929) Migrate server side error mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2929: --- Description: Kafka common and core both have a class that maps error codes and exceptions. To prevent

[jira] [Updated] (KAFKA-2929) Migrate server side error mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2929: --- Summary: Migrate server side error mapping functionality (was: Deprecate duplicate error mapping func

[jira] [Commented] (KAFKA-2997) Synchronous write to disk

[ https://issues.apache.org/jira/browse/KAFKA-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060260#comment-15060260 ] Flavio Junqueira commented on KAFKA-2997: - [~afirus] I'm not very sure of what you

[jira] [Commented] (KAFKA-2997) Synchronous write to disk

[ https://issues.apache.org/jira/browse/KAFKA-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060256#comment-15060256 ] Grant Henke commented on KAFKA-2997: I am curious about the motivation for synchronous

[jira] [Created] (KAFKA-2997) Synchronous write to disk

Arkadiusz Firus created KAFKA-2997: -- Summary: Synchronous write to disk Key: KAFKA-2997 URL: https://issues.apache.org/jira/browse/KAFKA-2997 Project: Kafka Issue Type: Improvement

[GitHub] kafka pull request: MINOR: Change return type of `Schema.read` to ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/684 MINOR: Change return type of `Schema.read` to be `Struct` instead of `Object` We always return a `Struct` from `Schema.read` and this means that we can remove a large number of casts. You can merg

[jira] [Commented] (KAFKA-2979) Enable authorizer and ACLs in ducktape tests

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

[GitHub] kafka pull request: KAFKA-2979: Enable authorizer and ACLs in duck...

GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/683 KAFKA-2979: Enable authorizer and ACLs in ducktape tests Patch by @fpj and @benstopford. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj/kafka KAF

[jira] [Created] (KAFKA-2996) Introduction around queue-like consumer group behaviour is misleading

Jakub Korab created KAFKA-2996: -- Summary: Introduction around queue-like consumer group behaviour is misleading Key: KAFKA-2996 URL: https://issues.apache.org/jira/browse/KAFKA-2996 Project: Kafka

[jira] [Commented] (KAFKA-2992) Trace log statements in the replica fetcher inner loop create large amounts of garbage

[ https://issues.apache.org/jira/browse/KAFKA-2992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15059891#comment-15059891 ] Ismael Juma commented on KAFKA-2992: I had a look at the code in question and I'm surp

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

See Changes: [wangguoz] MINOR: StreamThread performance optimization -- [...truncated 1391 lines...] kafka.log.LogTest > testIndexResizingAtTruncation PASSED kafka.log.LogTest > testCompactedTop

[jira] [Created] (KAFKA-2995) in 0.9.0.0 Old Consumer's commitOffsets with specify partition can submit not exists topic and partition to zk

Pengwei created KAFKA-2995: -- Summary: in 0.9.0.0 Old Consumer's commitOffsets with specify partition can submit not exists topic and partition to zk Key: KAFKA-2995 URL: https://issues.apache.org/jira/browse/KAFKA-2995

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

See Changes: [wangguoz] MINOR: StreamThread performance optimization -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docker Ubuntu ubu