Repository: kafka
Updated Branches:
refs/heads/trunk fe3699ce3 -> d1a9252ca
KAFKA-6349: Fix concurrent modification exception in AbstractStateManager
during restore
Fixes a `ConcurrentModificationException` in`AbstractStateManager` that is
triggered when a `StateStore` is re-initialized and
Repository: kafka
Updated Branches:
refs/heads/trunk b08882213 -> fe3699ce3
MINOR: Fix warn logging in RecordCollectorImpl
Fix warn log message in RecordCollectorImpl so it prints the exception message
rather than `{}`
Author: Damian Guy
Reviewers: Matthias J. Sax
Repository: kafka
Updated Branches:
refs/heads/trunk 0a508a436 -> b08882213
KAFKA-5764; Add toLowerCase support to sasl.kerberos.principal.to.local rule
(KIP-203)
Author: Manikumar Reddy
Reviewers: Jason Gustafson
Closes #3800 from
Repository: kafka
Updated Branches:
refs/heads/trunk 651c6e480 -> 0a508a436
KAFKA-5631; Use Jackson for serialising to JSON
- Rename `encode` to `legacyEncodeAsString`, we
can remove this when we remove `ZkUtils`.
- Introduce `encodeAsString` that uses Jackson.
- Change `encodeAsBytes` to use
Repository: kafka
Updated Branches:
refs/heads/1.0 a580a6b79 -> 8ba874cb8
KAFKA-6319: Quote strings stored in JSON configs
This is required for ACLs where SSL principals contain
special characters (e.g. comma) that are escaped using
backslash. The strings need to be quoted for JSON to
ensure
Repository: kafka
Updated Branches:
refs/heads/trunk a5cd34d79 -> 651c6e480
KAFKA-6319: Quote strings stored in JSON configs
This is required for ACLs where SSL principals contain
special characters (e.g. comma) that are escaped using
backslash. The strings need to be quoted for JSON to
KAFKA-6324; Change LogSegment.delete to deleteIfExists and harden log recovery
- Rename `delete()` to `deleteIfExists()` in `LogSegment`, `AbstractIndex`
and `TxnIndex`. Throw exception in case of IO errors for more informative
errors and to make it less likely that errors are ignored, `boolean`
Repository: kafka
Updated Branches:
refs/heads/trunk 72eec0a04 -> a5cd34d79
http://git-wip-us.apache.org/repos/asf/kafka/blob/a5cd34d7/core/src/test/scala/unit/kafka/producer/SyncProducerTest.scala
--
diff --git