GitHub user amethystic reopened a pull request:
https://github.com/apache/kafka/pull/3148
KAFKA-5327: ConsoleConsumer should manually commit offsets...
KAFKA-5327: ConsoleConsumer should manually commit offsets for those
records it really consumed. Currently it leaves this job to
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/3148
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/3188
KAFKA-5358: Consumer perf tool should count rebalance time.
Added 'join.group.ms' for new consumer to calculate the time of joining
group.
You can merge this pull request into a Git
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2054
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2317
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2576
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/3148
KAFKA-5327: ConsoleConsumer explicitly set `max.poll.records`...
KAFKA-5327: ConsoleConsumer explicitly set `max.poll.records` if
`--max-messages` is set.
You can merge this pull request into a
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/3100
KAFKA-5278: Have console-consumer support `--value-deserializer`
In the original implementation, console-consumer fails to honor
`--value-deserializer` config.
You can merge this pull request
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2962
Kafka5161 reassign-partitions to check if broker of ID exists in cluster
Added code to check existence of the brokers in the proposed plan.
You can merge this pull request into a Git repository
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2943
kafka-5413: Windows platform does not offer kafka-broker-api-versions.bat
Added kafka-broker-api-versions.bat for Windows platform
You can merge this pull request into a Git repository by
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2907
kafka-5118: Improve message for Kafka failed startup with non-Kafka data in
data.dirs
Explicitly throwing clear exceptions when starting up a Kafka with some
non-Kafka data in data.dirs.
You
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2905
kafka-5104: DumpLogSegments should not open index files with `rw`
Add a parameter 'writable' for AbstractIndex and set its default value to
true for its children classes.
You can
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2898
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2904
kafka-5901: ReassignPartitionsCommand should protect against empty reâ¦
ReassignPartitionsCommand should protect against empty replica list
assignment.
You can merge this pull request into a
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2902
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2902
kafka-5901: ReassignPartitionsCommand should protect against empty reâ¦
kafka-5901: ReassignPartitionsCommand should protect against empty replica
list assignment
Add logic code to throw
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2898
kafka-5104: DumpLogSegments should not open index files with `rw`
When issuing DumpLogSegments command, the underlying index files(including
timestamp index) will be opened with read-only mode
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2860
kafka-5068: Optionally print out metrics after running the perf tests
@junrao added a config `--print.metrics` to control whether
ProducerPerformance prints out metrics at the end of the test
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2661
kafka-4866: Kafka console consumer property is ignored
Added `print.value` config in ConsoleConsumer to match what the quickstart
document says.
You can merge this pull request into a Git
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2606
kafka4811: ReplicaFetchThread may fail to create due to existing metric
Have fetcherThreadMap keyed off brokerId + fetcherId instead of broker +
fetcherId, but did not consider the case where
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2576
kafka-4767: KafkaProducer is not joining its IO thread properly
KafkaProducer#close swallows the InterruptedException which might be
acceptable when it's invoked from within the main thre
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2490
kafka-4727: A Production server configuration needs to be updated
1. Update value for queued.max.requests to 500
2. Removed invalid config 'controller.message.queue.size'
3. Rem
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2419
kafka-4684: Kafka does not offer kafka-configs.bat on Windows box
Add kafka-configs.bat script for Windows.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2317
kafka-4592: Kafka Producer Metrics Invalid Value
Default constructor of Max assigns negative infinity as the init value.
For the record size and like, value of zero is more reasonable.
You
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2308
kafka-3739:Add no-arg constructor for library provided serdes
Add default constructor for library provided serdes
You can merge this pull request into a Git repository by running:
$ git
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2307
kafka-4434: KafkaProducer configuration is logged twice
ProducerConfig calls AbstractConfig.init where does the logs. KafkaProducer
init will inovoke ProducerConfig.init twice that leads to
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2304
kafka-4576: Log segments close to max size break on fetch
JVM spec does not make a guarantee that the buffer will be filled up when
invoking FileChannel.read, which is called in
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2156
kafka-4428: Kafka does not exit when it receives "Address already in use"
error during startup
kafka-4428: Kafka does not exit when it receives "Address already in use"
GitHub user amethystic reopened a pull request:
https://github.com/apache/kafka/pull/2072
Kafka-4351: Topic regex behavioral change with MirrorMaker new consumer
Support CSV values in the regexp for MirrorMaker new consumer as
OldConsumer does.
You can merge this pull request
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2072
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2058
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2072
Kafka-4351: Topic regex behavioral change with MirrorMaker new consumer
Support CSV values in the regexp for MirrorMaker new consumer as
OldConsumer does.
You can merge this pull request into a
GitHub user amethystic reopened a pull request:
https://github.com/apache/kafka/pull/2054
kafka-4295: ConsoleConsumer does not delete the temporary group in zookeeper
Since consumer stop logic and zk node removal code are in separate threads,
so when two threads execute in an
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2054
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2058
kafka-4295: ConsoleConsumer does not delete the temporary group in zookeeper
ConsoleConsumer does not delete the temporary group in zookeeper
Author: huxi...@hotmail.com
Since consumer
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2054
kafka-4295: ConsoleConsumer does not delete the temporary group in zookeeper
Since consumer stop logic and zk node removal code are in separate threads,
so when two threads execute in an
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2045
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic reopened a pull request:
https://github.com/apache/kafka/pull/2045
Fix for kafka-4295: kafka-console-consumer.sh does not delete the temporary
group in zookeeper
Since consumer stop logic and zk node removal code are in separate threads,
so when two threads
Github user amethystic closed the pull request at:
https://github.com/apache/kafka/pull/2045
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2045
Fix for kafka-4295: kafka-console-consumer.sh does not delete the temporary
group in zookeeper
Since consumer stop logic and zk node removal code are in separate threads,
so when two threads
GitHub user amethystic opened a pull request:
https://github.com/apache/kafka/pull/2037
add Windows script 'kafka-consumer-groups.bat' as issue Kafka-4310 mentions
add file 'kafka-consumer-groups.bat' for Windows platform
You can merge this pull request into
41 matches
Mail list logo
