Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1698
---
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3941
KAFKA-3999: Record raw size of fetch responses as part of consumer metrics
Currently, only the decompressed size of fetch responses is recorded. This
PR adds a sensor to keep track of the
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/3438
---
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3965
KAFKA-5944: Unit tests for handling SASL authentication failures in clients
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4062
KAFKA-6055: Fix a JVM misconfiguration that affects Windows tools
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/4083
MINOR: Improve a Windows quickstart instruction
The output of `wmic` can be very long and could truncate the search
keywords in the existing command. If those keywords are truncated no
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4135
KAFKA-5848: Perform a complete topic name validation in KafkaConsumer's
assign/subscribe
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4139
MINOR: Indentation Fix
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
minor/indentation_fix_1710
Alternatively
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4190
MINOR: Fix Javadoc Issues
This PR mainly fixes some broken links and invalid references in the
clients Javadoc
You can merge this pull request into a Git repository by running:
$ git
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4241
KAFKA-4893: Fix conflict between async topic deletion and max topic length
With async topic deletion the topic partition folder name is affixed with a
'.', a UUID, and '-de
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/3448
---
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4271
KAFKA-5526: Additional `--describe` views for ConsumerGroupCommand (KIP-175)
The `--describe` option of ConsumerGroupCommand is expanded to support:
* `--describe` or `--describe
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4333
MINOR: Use TopicPartition in ConsumerGroupCommand instead of
TopicAndPartition where possible
### Committer Checklist (excluded from commit message)
- [ ] Verify design and
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/4344
KAFKA-6321: Consolidate calls to KafkaConsumer's `beginningOffsets()` and
`endOffsets()` in ConsumerGroupCommand
### Committer Checklist (excluded from commit message)
- [ ] V
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3320
KAFKA-5370 (WIP): Replace uses of the old consumer with the new consumer
when possible
Also, methods in `ClientUtils` that are called by server or tools code
should be introduced in
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3387
MINOR: Update documentation to use `kafka-consumer-groups.sh` as the main
tool for checking consumer offsets
You can merge this pull request into a Git repository by running:
$ git
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3405
KAFKA-5495: Update docs to use `kafka-consumer-groups.sh` for checking
consumer offsets
And remove the deprecated `ConsumerOffsetChecker` example.
You can merge this pull request into a Git
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/3387
---
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3415
MINOR: Make 'Topic-Level Configs' a doc section for easier access
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashe
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3438
KAFKA-3465: Clarify warning message of ConsumerOffsetChecker
Add that the tool works with the old consumer only.
You can merge this pull request into a Git repository by running:
$ git
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3448
KAFKA-5526: Report group consumers while offsets are being initialized
Instead of reporting no rows in consumer group command's result for new
consumers while group offsets are
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3460
KAFKA-5534: `offsetForTimes` result should include partitions with no offset
For topics that support timestamp search, if no offset is found for a
partition, the partition should still be
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3593
KAFKA-5664: Disable auto offset commit in ConsoleConsumer if no group is
provided
This is to avoid polluting the Consumer Coordinator cache as the
auto-generated group and its offsets are
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3661
KAFKA-4585: Lower the Minimum Required ACL Permission of OffsetFetch
(KIP-163)
Details can be found in the
[KIP](https://cwiki.apache.org/confluence/display/KAFKA/KIP-163%3A+Lower+the
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3694
MINOR: Improve help doc of ConsumerGroupCommand
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
minor
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3832
KAFKA-5854: (WIP) Handle SASL authentication failures as non-retriable
exceptions in clients
This PR depends on the in progress [PR for
KAFKA-4764](https://github.com/apache/kafka/pull/3708
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/3854
MINOR: Fix LogContext message format in KafkaProducer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka
minor
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, or if the
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 the
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, or if the
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, or if the
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 the
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 the
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, or if the
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, or if the
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 the
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 the
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, or if the
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, or if the
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 the
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.
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, in
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, or if the
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/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
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
updatin
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 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, or if the
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 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/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 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 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, or if the
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, or if the
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/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, or if the
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/1572
KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern)
subscriptions
This patch fixes two issues:
1. Subsequent regex subscriptions fail with the new consumer.
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1572
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1572
KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern)
subscriptions
This patch fixes two issues:
1. Subsequent regex subscriptions fail with the new consumer.
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1572
KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern)
subscriptions
This patch fixes two issues:
1. Subsequent regex subscriptions fail with the new consumer.
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1572
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1572
KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern)
subscriptions
This patch fixes two issues:
1. Subsequent regex subscriptions fail with the new consumer.
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1572
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1572
KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern)
subscriptions
This patch fixes two issues:
1. Subsequent regex subscriptions fail with the new consumer.
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1572
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1572
KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern)
subscriptions
This patch fixes two issues:
1. Subsequent regex subscriptions fail with the new consumer.
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1572
---
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1594
KAFKA-3931: WIP
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka KAFKA-3931
Alternatively you can review and apply
Github user vahidhashemian closed the pull request at:
https://github.com/apache/kafka/pull/1594
---
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
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1594
KAFKA-3931: Fix transient failures in pattern subscription tests
Full credit for figuring out the cause of these failures goes to @hachikuji.
You can merge this pull request into a Git
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
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/1622
KAFKA-3859: Fix describe group command to report valid status when group is
empty
With the new consumer, when all consumers of a consumer group are stopped
(i.e. the group is empty), the
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
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 reopened 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, or if the
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, or if the
GitHub user vahidhashemian reopened a pull request:
https://github.com/apache/kafka/pull/1698
KAFKA-3999: Record raw size of fetch responses as part of consumer metrics
Currently, only the decompressed size of fetch responses is recorded. This
PR adds a sensor to keep track of the
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2146
KAFKA-4272: Add missing 'connect' Windows batch scripts
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/2150
KAFKA-4416: Add a `--group` option to console consumer
The value provided for this option overwrites any `group.id` value
indirectly provided via `consumer-property` or `consumer.config
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2160
KAFKA-4095: Remove topic offsets and owners from ZK consumer groups upon
topic deletion
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2189
KAFKA-4271: Fix the server start script for Windows to run normally on a
32-bit OS
Without this fix the new consumer fails to run on a 32-bit Windows OS.
You can merge this pull request
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2218
KAFKA-4480: Report an error in 'kafka-configs' command if the config to be
removed does not exist
You can merge this pull request into a Git repository by running:
$ git
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2238
MINOR: Sync up 'kafka-run-class.bat' with 'kafka-run-class.sh'
Some of the recent changes to `kafka-run-class.sh` have not been applied to
`kafka-run-class.bat`.
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2247
MINOR: Fix Streams examples in documentation
Performed minor cleanup and escaped `<` and `>` so code examples are shown
correctly in the browser.
You can merge this pull request into
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2300
KAFKA-4583: Fail the 'kafka-configs' command if the config to be removed
does not exist
You can merge this pull request into a Git repository by running:
$ git pull https://
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2302
KAFKA-4531: Centralize validation of configs for consumer and producer
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2595
MINOR: Fix typos in javadoc and code comments
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vahidhashemian/kafka minor/fix_typos_1702
GitHub user vahidhashemian opened a pull request:
https://github.com/apache/kafka/pull/2635
MINOR: additional refactoring around the use of Errors
A couple of updates were missed in the
[PR](https://github.com/apache/kafka/pull/2475) that replaced the use of error
codes with
1 - 100 of 226 matches
Mail list logo
