[GitHub] kafka pull request #3289: MINOR: add Yahoo benchmark to nightly runs

2017-06-10 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3289 MINOR: add Yahoo benchmark to nightly runs You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka yahoo-benchmark Alternatively

[GitHub] kafka pull request #3411: KAFKA-5487: upgrade and downgrade streams app syst...

2017-06-22 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3411 KAFKA-5487: upgrade and downgrade streams app system test You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5487

[GitHub] kafka pull request #3418: HOTFIX: Don't check metadata unless you are creati...

2017-06-23 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3418 HOTFIX: Don't check metadata unless you are creating topic During a broker rolling upgrade, it's likely we don't have enough brokers ready yet. If streams does not need to cr

[GitHub] kafka pull request #3423: KAFKA-5157: Options for handling corrupt data duri...

2017-06-23 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3423 KAFKA-5157: Options for handling corrupt data during deserialization [WiP] This is the implementation of KIP-161: https://cwiki.apache.org/confluence/display/KAFKA/KIP-161%3A+streams

[GitHub] kafka pull request #3424: MINOR: Typo in comments makes debug confusing

2017-06-23 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3424 MINOR: Typo in comments makes debug confusing You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-typo-debug

[GitHub] kafka pull request #3424: MINOR: Typo in comments makes debug confusing

2017-06-23 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3424 --- 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

[GitHub] kafka pull request #3432: KAFKA-5372: fixes to state transitions

2017-06-26 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3432 KAFKA-5372: fixes to state transitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5372-state-transitions

[GitHub] kafka pull request #3444: KAFKA-5006: Better exception messages when produci...

2017-06-27 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3444 KAFKA-5006: Better exception messages when producing You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5006

[GitHub] kafka pull request #3472: MINOR: Upgraded RocksDB to 5.1.2

2017-06-30 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3472 MINOR: Upgraded RocksDB to 5.1.2 You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-upgrade-rocksdb-5.1.2

[GitHub] kafka pull request #3479: MINOR: compatibility tests for streams

2017-07-03 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3479 MINOR: compatibility tests for streams Add on to https://github.com/apache/kafka/pull/3454 You can merge this pull request into a Git repository by running: $ git pull https://github.com

[GitHub] kafka pull request #3490: MINOR: Pass over DSL documentation up to stateful ...

2017-07-05 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3490 MINOR: Pass over DSL documentation up to stateful transformations You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor

[GitHub] kafka pull request #3491: HOTFIX: Fixes to metric names

2017-07-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3491 HOTFIX: Fixes to metric names A couple of fixes to metric names to match the KIP - Removed extra strings in the metric names that are already in the tags - add a separate metric for &quo

[GitHub] kafka pull request #3492: HOTFIX: Hotfix for trunk failing

2017-07-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3492 HOTFIX: Hotfix for trunk failing Disable 3 tests that need rethinking. You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka

[GitHub] kafka pull request #3492: HOTFIX: Hotfix for trunk failing

2017-07-06 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3492 --- 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

[GitHub] kafka pull request #3494: MINOR: Move quickstart under streams

2017-07-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3494 MINOR: Move quickstart under streams You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-quickstart-docs Alternatively

[GitHub] kafka pull request #3500: KAFKA-5566: Atomic compare and set

2017-07-07 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3500 KAFKA-5566: Atomic compare and set You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix-queryable-state Alternatively

[GitHub] kafka pull request #3505: MINOR: Reduce logging level

2017-07-07 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3505 MINOR: Reduce logging level You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-less-logs Alternatively you can review

[GitHub] kafka pull request #3444: KAFKA-5006: Better exception messages when produci...

2017-07-12 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3444 --- 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

[GitHub] kafka pull request #3490: MINOR: Pass over DSL documentation up to stateful ...

2017-07-18 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3490 --- 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

[GitHub] kafka pull request #3545: KAFKA-5499: Minor cleanup of commit code

2017-07-18 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3545 KAFKA-5499: Minor cleanup of commit code You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5499-commit-exceptions

[GitHub] kafka pull request #3622: HOTFIX: state transition cherry picking

2017-08-04 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3622 HOTFIX: state transition cherry picking Cherry picked from https://github.com/apache/kafka/pull/3432 You can merge this pull request into a Git repository by running: $ git pull https

[GitHub] kafka pull request #3623: HOTFIX: Ported over changes from trunk

2017-08-04 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3623 HOTFIX: Ported over changes from trunk - Cherry picked from #3432 - Minor checkstyle fixes to get to build You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka pull request #3649: MINOR: Add one more instruction

2017-08-09 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3649 MINOR: Add one more instruction You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-docker-docs Alternatively you can

[GitHub] kafka pull request #3656: MINOR: More failure testing

2017-08-11 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3656 MINOR: More failure testing You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-add-more-tests Alternatively you can

[GitHub] kafka pull request #3622: HOTFIX: state transition cherry picking

2017-08-15 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3622 --- 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

[GitHub] kafka pull request #3623: HOTFIX: state transition cherry picking for 0.10.2

2017-08-17 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3623 --- 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

[GitHub] kafka pull request #3490: MINOR: Pass over DSL documentation up to stateful ...

2017-08-18 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/3490 MINOR: Pass over DSL documentation up to stateful transformations Added the following documentation: - creating source streams from Kafka - stateless transformations - moved

[GitHub] kafka pull request #3691: HOTFIX: Cherrypicking state deadlock fix from 0.11

2017-08-18 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3691 HOTFIX: Cherrypicking state deadlock fix from 0.11 Cherrypicking additional changes made as part of this PR https://github.com/apache/kafka/pull/3622, back to trunk. You can merge this pull

[GitHub] kafka pull request #3490: MINOR: Pass over DSL documentation up to stateful ...

2017-08-20 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3490 --- 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

[GitHub] kafka pull request #3701: MINOR: Document how to create source streams and t...

2017-08-20 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3701 MINOR: Document how to create source streams and tables Originally reviewed as part of https://github.com/apache/kafka/pull/3490. You can merge this pull request into a Git repository by

[GitHub] kafka pull request #3711: MINOR: Stateless transformation documentation

2017-08-22 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3711 MINOR: Stateless transformation documentation Needs to come after https://github.com/apache/kafka/pull/3701 You can merge this pull request into a Git repository by running: $ git pull

[GitHub] kafka pull request #3730: MINOR: stateful docs for aggregates [WiP]

2017-08-24 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3730 MINOR: stateful docs for aggregates [WiP] You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-docs-aggregates

[GitHub] kafka pull request #3545: KAFKA-5499: Minor cleanup of commit code

2017-08-30 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/3545 --- 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

[GitHub] kafka pull request #3760: MINOR: add table of contents

2017-08-30 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/3760 MINOR: add table of contents You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-docs-toc Alternatively you can review

[GitHub] kafka pull request: MINOR: Removed 1/2 of the hardcoded sleep time...

2016-05-24 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1422 MINOR: Removed 1/2 of the hardcoded sleep times You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-integration

[GitHub] kafka pull request: KAFKA-3511: Initial commit for aggregators [Wi...

2016-05-24 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1424 KAFKA-3511: Initial commit for aggregators [WiP] Initial structure. Removed initialiser. Two simple aggregators. You can merge this pull request into a Git repository by running: $ git

[GitHub] kafka pull request: KAFKA-3511: Initial commit for aggregators [Wi...

2016-05-26 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/1424 --- 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

[GitHub] kafka pull request: KAFKA-3678: Removed sleep

2016-05-27 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1439 KAFKA-3678: Removed sleep You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3678-timeouts1 Alternatively you can

[GitHub] kafka pull request #1485: KAFKA-3805: Check if DB is null. Do not release lo...

2016-06-09 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1485 KAFKA-3805: Check if DB is null. Do not release locked resources You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA

[GitHub] kafka pull request #1526: KAFKA-3870: Removed name from Windows class

2016-06-20 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1526 KAFKA-3870: Removed name from Windows class You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka expose-names-dsl

[GitHub] kafka pull request #1533: KAFKA-3872: Reduce log cleaner buffer size to 2 MB

2016-06-20 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1533 KAFKA-3872: Reduce log cleaner buffer size to 2 MB You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3872-oom

[GitHub] kafka pull request #1619: KAFKA-3858: Basic printing of everything

2016-07-13 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1619 KAFKA-3858: Basic printing of everything You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3858-print-topology

[GitHub] kafka pull request #1621: MINOR: Added simple streams benchmark to system te...

2016-07-13 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1621 MINOR: Added simple streams benchmark to system tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka simple-benchmark

[GitHub] kafka pull request #1638: KAFKA-3911: Initial source materialization (WiP)

2016-07-19 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1638 KAFKA-3911: Initial source materialization (WiP) You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3911-ktable

[GitHub] kafka pull request #1645: HOTFIX: Adding init file so streams benchmark is a...

2016-07-20 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1645 HOTFIX: Adding init file so streams benchmark is autodiscovered Without this file the benchmark does not run nightly. You can merge this pull request into a Git repository by running

[GitHub] kafka pull request #1674: HOTFIX: Fixes to javadoc and to state store name f...

2016-07-28 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1674 HOTFIX: Fixes to javadoc and to state store name for link joins You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix

[GitHub] kafka pull request #1700: KAFKA-4016: Added join benchmarks

2016-08-03 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/1700 KAFKA-4016: Added join benchmarks You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka join-benchmarks Alternatively you can

[GitHub] kafka pull request #2124: KAFKA-4359: Removed commit interval

2016-11-11 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2124 KAFKA-4359: Removed commit interval You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4359-intergration-tests

[GitHub] kafka pull request #2133: KAFKA-4355: Skip topics that have no partitions

2016-11-15 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2133 KAFKA-4355: Skip topics that have no partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4355-topic-not

[GitHub] kafka pull request #2135: KAFKA-3637: Added initial states

2016-11-15 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2135 KAFKA-3637: Added initial states You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3637-streams-state Alternatively

[GitHub] kafka pull request #2133: KAFKA-4355: Skip topics that have no partitions

2016-11-18 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2133 --- 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

[GitHub] kafka pull request #2133: KAFKA-4355: Skip topics that have no partitions

2016-11-18 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2133 KAFKA-4355: Skip topics that have no partitions You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4355-topic-not

[GitHub] kafka pull request #2149: HOTFIX: Hotfix streams smoke test

2016-11-18 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2149 HOTFIX: Hotfix streams smoke test You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix-streams-smoke-test

[GitHub] kafka pull request #2154: HOTFIX: Increased wait time

2016-11-21 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2154 HOTFIX: Increased wait time You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix_streams Alternatively you can review

[GitHub] kafka pull request #2154: HOTFIX: Increased wait time

2016-11-22 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2154 --- 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

[GitHub] kafka pull request #2171: KAFKA-4427: Skip topic groups with no tasks

2016-11-25 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2171 KAFKA-4427: Skip topic groups with no tasks You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4427-topicgroups-with

[GitHub] kafka pull request #2135: KAFKA-3637: Added initial states

2016-11-28 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2135 KAFKA-3637: Added initial states You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3637-streams-state

[GitHub] kafka pull request #2171: KAFKA-4427: Skip topic groups with no tasks

2016-11-28 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2171 KAFKA-4427: Skip topic groups with no tasks You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4427-topicgroups

[GitHub] kafka pull request #2171: KAFKA-4427: Skip topic groups with no tasks

2016-11-28 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2171 --- 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

[GitHub] kafka pull request #2135: KAFKA-3637: Added initial states

2016-11-28 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2135 --- 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

[GitHub] kafka pull request #2135: KAFKA-3637: Added initial states

2016-11-29 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2135 KAFKA-3637: Added initial states You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3637-streams-state

[GitHub] kafka pull request #2135: KAFKA-3637: Added initial states

2016-11-29 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2135 --- 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

[GitHub] kafka pull request #2193: KAFKA-4405: Check max.poll.records before prefetch...

2016-11-30 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2193 KAFKA-4405: Check max.poll.records before prefetching You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4405-prefetch

[GitHub] kafka pull request #2193: KAFKA-4405: Check max.poll.records before prefetch...

2016-12-01 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2193 --- 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

[GitHub] kafka pull request #2193: KAFKA-4405: Check max.poll.records before prefetch...

2016-12-01 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2193 KAFKA-4405: Check max.poll.records before prefetching You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4405

[GitHub] kafka pull request #2198: HOTFIX: Forgot one transition

2016-12-01 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2198 HOTFIX: Forgot one transition You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix-stream-states Alternatively you can

[GitHub] kafka pull request #2199: HOTFIX: Temporary suspension of 2 tests

2016-12-01 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2199 HOTFIX: Temporary suspension of 2 tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix-streams-test-reset-ignore

[GitHub] kafka pull request #2199: HOTFIX: Temporary suspension of 2 tests

2016-12-03 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2199 --- 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

[GitHub] kafka pull request #2215: KAFKA-3537: Expose metrics registry

2016-12-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2215 KAFKA-3537: Expose metrics registry You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-3537-access-low-level-metrics

[GitHub] kafka pull request #2199: HOTFIX: Temporary suspension of 2 tests

2016-12-06 Thread enothereska
GitHub user enothereska reopened a pull request: https://github.com/apache/kafka/pull/2199 HOTFIX: Temporary suspension of 2 tests You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix-streams-test-reset

[GitHub] kafka pull request #2217: HOTFIX: Disable test until fixed

2016-12-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2217 HOTFIX: Disable test until fixed You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka hotfix-disable-smoke-test Alternatively

[GitHub] kafka pull request #2219: HOTFIX: Disable this test until it's fixed (0.10.1...

2016-12-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2219 HOTFIX: Disable this test until it's fixed (0.10.1) You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka 0.10.1-h

[GitHub] kafka pull request #2219: HOTFIX: Disable this test until it's fixed (0.10.1...

2016-12-07 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2219 --- 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

[GitHub] kafka pull request #2225: KAFKA-4486: Don't commit offsets on exception

2016-12-07 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2225 KAFKA-4486: Don't commit offsets on exception You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4486-exception-c

[GitHub] kafka pull request #2252: HOTFIX: fix state transition stuck on rebalance

2016-12-13 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2252 HOTFIX: fix state transition stuck on rebalance This fixes a problem where the Kafka instance state transition gets stuck on rebalance. Also adjusts the test in QueryableStateIntegration test

[GitHub] kafka pull request #2257: MINOR: Reenable streams smoke test

2016-12-14 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2257 MINOR: Reenable streams smoke test I ran it 3 times and it works again. You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka

[GitHub] kafka pull request #2283: HOTFIX: Convert exception to warning since clearly...

2016-12-20 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2283 HOTFIX: Convert exception to warning since clearly it is happening. You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka

[GitHub] kafka pull request #2601: KAFKA-4744: Increased timeout for bounce test

2017-02-26 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2601 KAFKA-4744: Increased timeout for bounce test You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4744-bounce

[GitHub] kafka pull request #2603: MINOR: Minor reduce unnecessary calls to time.mill...

2017-02-27 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2603 MINOR: Minor reduce unnecessary calls to time.millisecond (part 2) Avoid calling time.milliseconds more often than necessary. Cleaning and committing logic can use the timestamp at the start of

[GitHub] kafka pull request #2634: MINOR: Standardised benchmark params for consumer ...

2017-03-03 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2634 MINOR: Standardised benchmark params for consumer and streams There were some minor differences in the basic consumer config and streams config that are now rectified. In addition, in AWS

[GitHub] kafka pull request #2643: KAFKA-4843: More efficient round-robin scheduler

2017-03-05 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2643 KAFKA-4843: More efficient round-robin scheduler - Improves streams efficiency by more than 200K requests/second (small 100 byte requests) - Gets streams efficiency very close to pure

[GitHub] kafka pull request #2652: MINOR: add warning when offset topic is not replic...

2017-03-07 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2652 MINOR: add warning when offset topic is not replicated properly Added a warning, otherwise this problem is hard to debug if you haven't followed the latest KIP closely. You can merge this

[GitHub] kafka pull request #2663: MINOR: increase RocksDb parallelism

2017-03-09 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2663 MINOR: increase RocksDb parallelism You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-rocksdb-parallel Alternatively

[GitHub] kafka pull request #2719: KAFKA-4916: test streams with brokers failing [WiP...

2017-03-21 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2719 KAFKA-4916: test streams with brokers failing [WiP] You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4916-broker

[GitHub] kafka pull request #2728: KAFKA 3514: alternate calculation for min timestam...

2017-03-23 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2728 KAFKA 3514: alternate calculation for min timestamp [WiP] This alternate calculation reduces the amount of buffering kept and is optimised for cases when out of order records are rare. You

[GitHub] kafka pull request #2764: MINOR: reduce amount of verbose printing

2017-03-30 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2764 MINOR: reduce amount of verbose printing You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-remove-verboseprint

[GitHub] kafka pull request #2770: MINOR: Increase max.poll time for streams consumer...

2017-03-30 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2770 MINOR: Increase max.poll time for streams consumers You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-increase-max

[GitHub] kafka pull request #2793: KAFKA-4916: test streams with brokers failing (for...

2017-04-03 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2793 KAFKA-4916: test streams with brokers failing (for 0.10.2) You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-4916

[GitHub] kafka pull request #2803: MINOR: improve MinTimestampTrackerTest and fix NPE...

2017-04-04 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2803 MINOR: improve MinTimestampTrackerTest and fix NPE when null element Cherry picked from trunk fix https://github.com/apache/kafka/pull/2611 You can merge this pull request into a Git repository

[GitHub] kafka pull request #2804: MINOR: don't throw CommitFailedException during su...

2017-04-04 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2804 MINOR: don't throw CommitFailedException during suspendTasksAndState Cherrypicked from trunk https://github.com/apache/kafka/pull/2535 You can merge this pull request into a Git reposito

[GitHub] kafka pull request #2804: MINOR: don't throw CommitFailedException during su...

2017-04-04 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2804 --- 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

[GitHub] kafka pull request #2803: MINOR: improve MinTimestampTrackerTest and fix NPE...

2017-04-04 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2803 --- 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

[GitHub] kafka pull request #2817: MINOR: Improve log4j on stream thread and stream p...

2017-04-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2817 MINOR: Improve log4j on stream thread and stream process Cherry pick from https://github.com/apache/kafka/pull/2685 You can merge this pull request into a Git repository by running: $ git

[GitHub] kafka pull request #2817: MINOR: Improve log4j on stream thread and stream p...

2017-04-06 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2817 --- 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

[GitHub] kafka pull request #2793: KAFKA-4916: test streams with brokers failing (for...

2017-04-06 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2793 --- 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

[GitHub] kafka pull request #2819: MINOR: Increase number of retries from the default...

2017-04-06 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2819 MINOR: Increase number of retries from the default of 0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-increase

[GitHub] kafka pull request #2824: MINOR: Added changes in 0.10.2.1

2017-04-07 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2824 MINOR: Added changes in 0.10.2.1 You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka minor-docs-0.10.2.1 Alternatively you

[GitHub] kafka pull request #2832: KAFKA-5045: KTable cleanup [WiP]

2017-04-10 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2832 KAFKA-5045: KTable cleanup [WiP] You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5045-ktable Alternatively you can

[GitHub] kafka pull request #2841: KAFKA-5038: Catch exception

2017-04-11 Thread enothereska
GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2841 KAFKA-5038: Catch exception You can merge this pull request into a Git repository by running: $ git pull https://github.com/enothereska/kafka KAFKA-5038 Alternatively you can review and

[GitHub] kafka pull request #2841: KAFKA-5038: Catch exception

2017-04-12 Thread enothereska
Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2841 --- 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

  1   2   >