Repository: kafka
Updated Branches:
refs/heads/trunk b5b266eee -> 6ea4fffdd
KAFKA-6003; Accept appends on replicas unconditionally when local producer
state doesn't exist
Without this patch, if the replica's log was somehow truncated before
the leader's, it is possible for the replica
Repository: kafka
Updated Branches:
refs/heads/1.0 [created] 5792f2fb3
Repository: kafka
Updated Branches:
refs/heads/1.0.0 [deleted] 5dab884d7
Repository: kafka
Updated Branches:
refs/heads/trunk 20d9adb17 -> b5b266eee
KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when
handling IsrChangeNotification event
Author: Dong Lin
Reviewers: Ismael Juma , Jun Rao
Repository: kafka
Updated Branches:
refs/heads/1.0.0 0222a35db -> 5dab884d7
KAFKA-5879; Controller should read the latest IsrChangeNotification znodes when
handling IsrChangeNotification event
Author: Dong Lin
Reviewers: Ismael Juma , Jun Rao
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 72b3bc737 -> 851b2683e (forced update)
Repository: kafka
Updated Branches:
refs/heads/trunk 6bcbd17d3 -> 20d9adb17
KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory
failure
Author: Dong Lin
Reviewers: Ismael Juma , Jun Rao
Closes #3718 from
Repository: kafka
Updated Branches:
refs/heads/1.0.0 5792f2fb3 -> 0222a35db
KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log directory
failure
Author: Dong Lin
Reviewers: Ismael Juma , Jun Rao
Closes #3718 from
Repository: kafka
Updated Branches:
refs/heads/trunk 5792f2fb3 -> 6bcbd17d3
Bump up version to 1.1.0-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6bcbd17d
Tree:
Repository: kafka
Updated Branches:
refs/heads/1.0.0 [created] 5792f2fb3
Repository: kafka
Updated Branches:
refs/heads/trunk 713a67fdd -> 5792f2fb3
KAFKA-5980: FailOnInvalidTimestamp does not log error
Author: Matthias J. Sax
Reviewers: Damian Guy , Ted Yu ,
Denis Bolshakov
Closes #3966 from
Repository: kafka
Updated Branches:
refs/heads/trunk 51c652c40 -> 713a67fdd
http://git-wip-us.apache.org/repos/asf/kafka/blob/713a67fd/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java
--
diff
MINOR: add suppress warnings annotations in Streams API
- fixes examples with regard to new API
- fixes `Topology#addGlobalStore` parameters
Author: Matthias J. Sax
Reviewers: Ismael Juma , Guozhang Wang ,
Damian Guy
Repository: kafka
Updated Branches:
refs/heads/trunk 06738b41b -> 51c652c40
KAFKA-6010; Relax record conversion time test to avoid build failure
For record conversion tests, check time >=0 since conversion times may be too
small to be measured accurately. Since default value is -1, the test
Repository: kafka
Updated Branches:
refs/heads/trunk 93b71e7de -> 06738b41b
MINOR: JavaDoc improvements for new state store API
Author: Matthias J. Sax
Reviewers: Michael G. Noll , Bill Bejeck
, Guozhang Wang
Repository: kafka
Updated Branches:
refs/heads/trunk ac7695c32 -> 93b71e7de
MINOR: update streams quickstart for KIP-182
Author: Damian Guy
Reviewers: Michael G. Noll , Bill Bejeck
, Matthias J. Sax ,
Repository: kafka
Updated Branches:
refs/heads/0.11.0 51ea8e76b -> ab554caee
KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking
Author: Rajini Sivaram
Reviewers: Guozhang Wang , Ismael Juma ,
Jason
Repository: kafka
Updated Branches:
refs/heads/trunk f8621b417 -> ac7695c32
KAFKA-6008: Sanitize the app id before creating app id metric
Author: Jakub Scholz
Reviewers: Randall Hauch , Ewen Cheslack-Postava
Closes #4012 from
Repository: kafka
Updated Branches:
refs/heads/trunk d985513b2 -> f8621b417
KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid blocking
Author: Rajini Sivaram
Reviewers: Guozhang Wang , Ismael Juma ,
Jason
Repository: kafka
Updated Branches:
refs/heads/trunk 11afff099 -> d985513b2
MINOR: streams dev guide fixup
Author: Joel Hamill
Author: Joel Hamill <11722533+joel-ham...@users.noreply.github.com>
Reviewers: Derrick Or , Michael G. Noll
Repository: kafka
Updated Branches:
refs/heads/trunk c6e5a32d0 -> 11afff099
KAFKA-5990: Enable generation of metrics docs for Connect (KIP-196)
A new mechanism was added recently to the Metrics framework to make it easier
to generate the documentation. It uses a registry with a
Repository: kafka
Updated Branches:
refs/heads/trunk 2a1b39ef1 -> c6e5a32d0
KAFKA-5856; AdminClient.createPartitions() follow up
- Improve tests and javadoc (including expected exceptions)
- Return correct authorization error if no describe topic
permission
Author: Tom Bentley
Repository: kafka
Updated Branches:
refs/heads/trunk 9949e1ed1 -> 2a1b39ef1
MINOR: Simplify log cleaner and fix compiler warnings
- Simplify LogCleaner.cleanSegments and add comment regarding thread
unsafe usage of `LogSegment.append`. This was a result of investigating
KAFKA-4972.
- Fix
Repository: kafka
Updated Branches:
refs/heads/trunk 5afeddaa9 -> 9949e1ed1
KAFKA-6004; Allow authentication providers to override error message
Author: Rajini Sivaram
Reviewers: Ismael Juma
Closes #4015 from
Repository: kafka
Updated Branches:
refs/heads/0.11.0 fae2d2386 -> 51ea8e76b
KAFKA-5967; Ineffective check of negative value in
CompositeReadOnlyKeyValueStore#approximateNumEntries()
package name: org.apache.kafka.streams.state.internals
Minor change to approximateNumEntries() method in
Repository: kafka
Updated Branches:
refs/heads/trunk 5383f9bed -> 5afeddaa9
KAFKA-5967; Ineffective check of negative value in
CompositeReadOnlyKeyValueStore#approximateNumEntries()
package name: org.apache.kafka.streams.state.internals
Minor change to approximateNumEntries() method in
MINOR: Use SecurityProtocol in AuthenticationContext
Since we removed the unused `TRACE` option from `SecurityProtocol`, it now
seems safer to expose it from `AuthenticationContext`. Additionally this patch
exposes javadocs under security.auth and relocates the `Login` and
Repository: kafka
Updated Branches:
refs/heads/trunk 198302fee -> 5383f9bed
http://git-wip-us.apache.org/repos/asf/kafka/blob/5383f9be/core/src/test/scala/integration/kafka/api/SslEndToEndAuthorizationTest.scala
--
diff --git
Repository: kafka
Updated Branches:
refs/heads/trunk a202da742 -> c4b8a7eab
KAFKA-5738; Upgrade note for cumulative count metric (KIP-187)
Author: Rajini Sivaram
Reviewers: Ismael Juma
Closes #4014 from rajinisivaram/MINOR-upgrade-KIP-187
Repository: kafka
Updated Branches:
refs/heads/trunk 28aaba281 -> a202da742
KAFKA-4764; Upgrade notes for authentication failure handling (KIP-152)
Author: Rajini Sivaram
Reviewers: Ismael Juma
Closes #4013 from
Repository: kafka
Updated Branches:
refs/heads/trunk cbef33f3d -> 28aaba281
MINOR: Java 9 version handling improvements
- Upgrade Gradle to 4.2.1, which handles Azul Zulu 9's version
correctly.
- Add tests to our Java version handling code
- Refactor the code to make it possible to add tests
31 matches
Mail list logo