kafka
kafka copied to clipboard
apache
Mirror of Apache Kafka
Jira: https://issues.apache.org/jira/browse/KAFKA-17338 add a validator for consumer group protocol, when setting partition.assignment.strategy ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify...
*What* Currently in `ShareConsumeRequestManager`, after we receive a `ShareFetchResponse`, if the subscription changes before we acknowledge(via `ShareFetch`), then we do not acknowledge the records which are not part of the...
Fix the dangling java doc comment for `ByteUtilsBenchmark` class, by putting the comment block on the header of class declaration and annotations ### Committer Checklist (excluded from commit message) -...
This is a too minor pull request that aims to remove a never thrown exception from `testUnsignedReadVarlongUnrolled` on [ByteUtilsBenchmark.java](https://github.com/apache/kafka/compare/trunk...bmscomp:fix/remove_unthrowed_exception?expand=1#diff-8054555a896a2cce2f6b28e2c14f4c11ca8f98e67ff6bcff671d1873d0ba427c) ### Committer Checklist (excluded from commit message) - [x] Verify design...
skip loading remaining logs if we encounter an unrecoverable error on startup @hachikuji @ijuma
This script does not work on Kafka1.0. Kafka1.0 work well to use this script to stop the process.
jcenter is a super set on top of maven central, so having both of those repositories is redundant, and the preferred one should be jcenter.
As pointed out in this thread: http://search-hadoop.com/m/Kafka/uyzND1fy2K7I85G1?subj=Kafka+source+code+Build+Error , Eclipse shows syntax error for the following: ``` return new KeyValue(mapper.apply(key, value), value); ```
First part of [KIP-877](https://cwiki.apache.org/confluence/display/KAFKA/KIP-877%3A+Mechanism+for+plugins+and+connectors+to+register+metrics). This adds the public APIs and enables the following plugins: - Serializer - Deserializer - ProducerInterceptor - ConsumerInterceptor - Partitioner which are all the Producer and...
related to https://issues.apache.org/jira/browse/KAFKA-17721, as title, configure controller lister name and security protocol in new test framework ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation...
