GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/641
KAFKA-2957: Fix typos in Kafka documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-2957
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/662
MINOR: Fix typos in code comments
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
typo02/fix_typos_in_code_comments
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/692
MINOR: Fix Broken Documentation Link
The link to 'Producer Configs' section of the documentation is updated with
this PR.
You can merge this pull request into a Git repository by running
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/673
MINOR: Fix typos in code comments
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
typo02/fix_typos_in_code_comments
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/662
---
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 user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/706
---
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 user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/706
Update 2015-12-21
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka trunk
Alternatively you can review and apply
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/707
MINOR: Fix typo in documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
typo04/fix_documentation_typos
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/692
---
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 user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/692
MINOR: Fix broken documentation link
The link to 'Producer Configs' section of the documentation is updated with
this PR.
You can merge this pull request into a Git repository by running
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1495
Minor: Respect the default value for partition argument in
SimpleConsumerShell
The `partition` argument is not marked as required, and has a default of
`0`, according to the tool's help
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1492
---
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1492
Change Mirror Maker default assignment strategy to round robin
Update Mirror Maker to to use round robin assignment by default since it
gives a better balance between the instances
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1493
KAFKA-3818: Change Mirror Maker default assignment strategy to round robin
Update Mirror Maker to use round robin assignment by default since it gives
a better balance between the instances
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1499
KAFKA-3831: Prepare for updating Mirror Maker's default partition
assignment strategy to round robin
This patch adds proper warning message and necessary doc updates for
updating
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1500
MINOR: Fix javadoc typos in ConsumerRebalanceListener
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
typo07
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1440
MINOR: Fix a couple of typos
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
typo06/fix_typos_in_code_comments
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1457
KAFKA-3774: Make 'time' an optional argument of GetOffsetShell tool
Since the 'time' argument has a default value of -1, it makes sense to make
it an optional argument.
You can merge
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1536
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1536
MINOR: KAFKA-3176 Follow-up to fix minor issues
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka minor/KAFKA-3176
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1536
MINOR: KAFKA-3176 Follow-up to fix minor issues
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka minor/KAFKA-3176
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1500
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1500
MINOR: Fix javadoc typos in ConsumerRebalanceListener
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
typo07
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/922
---
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 user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/922
KAFKA-3176: Add partition/offset options to the new consumer
With this pull request the new console consumer can be provided with
optional --partition and --offset arguments so only
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/922
---
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 user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1336
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/922
KAFKA-3176: Add partition/offset options to the new consumer
With this pull request the new console consumer can be provided with
optional --partition and --offset arguments so only
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1336
KAFKA-3144: Report members with no assigned partitions in
ConsumerGroupCommand
This PR makes a couple of enhancements to the `--describe` option of
`ConsumerGroupCommand`:
1. Listing
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/922
KAFKA-3176: Add partition/offset options to the new consumer
With this pull request the new console consumer can be provided with
optional --partition and --offset arguments so only
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/922
---
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 user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1336
KAFKA-3144: Report members with no assigned partitions in
ConsumerGroupCommand
This PR makes a couple of enhancements to the `--describe` option of
`ConsumerGroupCommand`:
1. Listing
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1336
---
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/778
MINOR: Improve Kafka documentation
Improve the documentation by fixing typos, punctuations, and correcting the
content.
You can merge this pull request into a Git repository by running
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/788
---
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 user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/788
KAFKA-3111: Fix ConsumerPerformance output for zero interval lengths
Interval lengths for ConsumerPerformance could sometime be calculated as
zero. In such cases, when the bytes read
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/788
KAFKA-3111: Fix ConsumerPerformance output for zero interval lengths
Interval lengths for ConsumerPerformance could sometime be calculated as
zero. In such cases, when the bytes read
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/898
KAFKA-3219: Fix long topic name validation
This fixes an issue with long topic names by considering, during topic
validation, the '-' and the partition id that is appended to the log
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/932
KAFKA-2832: Add a consumer config option to exclude internal topics
A new consumer config option 'exclude.internal.topics' was added to allow
excluding internal topics when wildcards
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/932
---
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 user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/813
KAFKA-3116: Specify minimum Gradle version required in Readme
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/813
---
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 user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/813
KAFKA-3116: Specify minimum Gradle version required in Readme
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/922
KAFKA-3176: Add partition/offset options to both old and new console
consumers
With this pull request both old and new console consumers can be provided
with optional --partition
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/922
KAFKA-3176: Add partition/offset options to both old and new console
consumers
With this pull request both old and new console consumers can be provided
with optional --partition
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/922
---
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 user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/932
KAFKA-2832: Add a consumer config option to exclude internal topics
A new consumer config option 'exclude.internal.topics' was added to allow
excluding internal topics when wildcards are used
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/932
KAFKA-2832: Add a consumer config option to exclude internal topics
A new consumer config option 'exclude.internal.topics' was added to allow
excluding internal topics when wildcards
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/932
---
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 user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1025
KAFKA-3312: Add utility offset methods to ZkUtils
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-3312
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1020
KAFKA-2273: Sticky partition assignment strategy
This PR implements a new partition assignment strategy called "sticky", and
it's purpose is to balance partitions across consumer
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1020
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1020
KAFKA-2273: Sticky partition assignment strategy
This PR implements a new partition assignment strategy called "sticky", and
it's purpose is to balance partitions across consumer
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1025
KAFKA-3312: Add utility offset methods to ZkUtils
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-3312
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1020
KAFKA-2273: Sticky partition assignment strategy
This PR implements a new partition assignment strategy called "sticky", and
it's purpose is to balance partitions across consumer
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1020
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1020
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1020
KAFKA-2273: Sticky partition assignment strategy
This PR implements a new partition assignment strategy called "sticky", and
it's purpose is to balance partitions across consumer
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1025
KAFKA-3312: Add utility offset methods to ZkUtils
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-3312
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1025
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1025
---
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1268
KAFKA-3614: Consolidate duplicate code in KGroupedTableImpl
Two methods aggregate() and reduce() share common code that is consolidated
in this patch.
You can merge this pull request
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1268
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1239
KAFKA-3579 - Update reference to the outdated consumer property
Replace references to the old consumer property 'fetch.message.max.bytes'
with the corresponding property in the new
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1239
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1239
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1239
KAFKA-3579 - Update reference to the outdated consumer property
Replace references to the old consumer property 'fetch.message.max.bytes'
with the corresponding property in the new
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1257
KAFKA-3608: Fix ZooKeeper structures and output format in documentation
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1239
KAFKA-3579 - Update reference to the outdated consumer property
Replace references to the old consumer property 'fetch.message.max.bytes'
with the corresponding property in the new
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1239
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1257
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1239
KAFKA-3579 - Update reference to the outdated consumer property
Replace references to the old consumer property 'fetch.message.max.bytes'
with the corresponding property in the new
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1239
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit offset of unsubscribed partitions of the new consumer on
a subscription change
When users are using group management, if they call consumer.subscribe() to
change
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit offset of unsubscribed partitions of the new consumer on
a subscription change
When users are using group management, if they call consumer.subscribe() to
change
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit offset of unsubscribed partitions of the new consumer on
a subscription change
When users are using group management, if they call consumer.subscribe() to
change
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit offset of unsubscribed partitions of the new consumer on
a subscription change
When users are using group management, if they call consumer.subscribe() to
change
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664 (WIP): Commit offset of unsubscribed partitions of the new
consumer on a subscription change
When users are using group management, if they call consumer.subscribe() to
change
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit offset of unsubscribed partitions of the new consumer on
a subscription change
When users are using group management, if they call consumer.subscribe() to
change
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit offset of unsubscribed partitions of the new consumer on
a subscription change
When users are using group management, if they call consumer.subscribe() to
change
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1363
---
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1363
KAFKA-3664: Commit unsubscribed partitions of the new consumer on a
subscription change
When users are using group management, if they call consumer.subscribe() to
change the subscription
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1025
KAFKA-3312: Add utility offset methods to ZkUtils
Create utility getOffset(...) and updateOffset(...) methods to replace
readData(...), readDataMaybeNull(...) and updatePersistentPath
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1025
---
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
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/932
---
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 user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1239
KAFKA-3579 - Update reference to the outdated consumer property
Replace references to the old consumer property 'fetch.message.max.bytes'
with the corresponding property in the new consumer
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1239
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1239
KAFKA-3579 - Update reference to the outdated consumer property
Replace references to the old consumer property 'fetch.message.max.bytes'
with the corresponding property in the new
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1336
KAFKA-3144: Report members with no assigned partitions in
ConsumerGroupCommand
This PR makes a couple of enhancements to the `--describe` option of
`ConsumerGroupCommand`:
1. Listing
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1618
KAFKA-3945: Fix validation of 'acks' config in console producer
The `acks` config that is provided to console producer with
`request-required-acks` comes with `all`, `-1`, `0`, `1` as valid
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1655
KAFKA-3982: Fix processing order of some of the consumer properties
This PR updates processing of console consumer's input properties.
For both old and new consumer, the value
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1684
KAFKA-4000: Aggregate partitions of each topic for consumer metrics
Fix the consumer metric collection to record metrics per topic instead of
per partition of topic.
You can merge this pull
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1698
KAFKA-3999: Record raw size of fetch responses
Currently, only the decompressed size of fetch responses is recorded. This
PR adds a sensor to keep track of the raw size as well.
You can
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1698
---
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
1 - 100 of 220 matches
Mail list logo
