kafka git commit: KAFKA-6349: Fix concurrent modification exception in AbstractStateManager during restore

2017-12-12 Thread guozhang
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

kafka git commit: MINOR: Fix warn logging in RecordCollectorImpl

2017-12-12 Thread guozhang
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

kafka git commit: KAFKA-5764; Add toLowerCase support to sasl.kerberos.principal.to.local rule (KIP-203)

2017-12-12 Thread jgus
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

kafka git commit: KAFKA-5631; Use Jackson for serialising to JSON

2017-12-12 Thread ijuma
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

kafka git commit: KAFKA-6319: Quote strings stored in JSON configs

2017-12-12 Thread ijuma
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

kafka git commit: KAFKA-6319: Quote strings stored in JSON configs

2017-12-12 Thread ijuma
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

[2/2] kafka git commit: KAFKA-6324; Change LogSegment.delete to deleteIfExists and harden log recovery

2017-12-12 Thread ijuma
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`

[1/2] kafka git commit: KAFKA-6324; Change LogSegment.delete to deleteIfExists and harden log recovery

2017-12-12 Thread ijuma
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