Repository: kafka
Updated Branches:
refs/heads/trunk e2e8d4a57 -> a1ea53606
KAFKA-5541: Streams should not re-throw if suspending/closing tasks fails
Author: Matthias J. Sax
Reviewers: Damian Guy , Bill Bejeck ,
Guozhang Wang
Closes #4037 from mjsax/kafka-5541-dont-rethrow-on-suspend-or-c
Repository: kafka
Updated Branches:
refs/heads/1.0 f899c735d -> 529873146
MINOR: KIP-161 upgrade docs change
Author: Guozhang Wang
Reviewers: Damian Guy
Closes #4036 from guozhangwang/KMinor-kip-161-docs
(cherry picked from commit e2e8d4a57a83693b946c3e26f9be2e41a7341ab4)
Signed-off-by: G
Repository: kafka
Updated Branches:
refs/heads/trunk 51063441d -> e2e8d4a57
MINOR: KIP-161 upgrade docs change
Author: Guozhang Wang
Reviewers: Damian Guy
Closes #4036 from guozhangwang/KMinor-kip-161-docs
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-
Repository: kafka
Updated Branches:
refs/heads/1.0 d3a603cb9 -> f899c735d
KAFKA-5362; Follow up to Streams EOS system test
- improve tests to get rid of calls to `sleep` in Python
- fixed some flaky test conditions
- improve debugging
Author: Matthias J. Sax
Reviewers: Damian Guy , Bill
Repository: kafka
Updated Branches:
refs/heads/trunk 91517e8fb -> 51063441d
KAFKA-5362; Follow up to Streams EOS system test
- improve tests to get rid of calls to `sleep` in Python
- fixed some flaky test conditions
- improve debugging
Author: Matthias J. Sax
Reviewers: Damian Guy , Bil
Repository: kafka
Updated Branches:
refs/heads/1.0 963733cd0 -> d3a603cb9
KAFKA-5829; Only delete producer snapshots before the recovery point
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #4023 from ijuma/kafka-5829-avoid-reading-older-segments-on-hard-shutdown
(cherry picked fro
Repository: kafka
Updated Branches:
refs/heads/trunk 2427a4476 -> 91517e8fb
KAFKA-5829; Only delete producer snapshots before the recovery point
Author: Ismael Juma
Reviewers: Jason Gustafson
Closes #4023 from ijuma/kafka-5829-avoid-reading-older-segments-on-hard-shutdown
Project: http:/
Repository: kafka
Updated Branches:
refs/heads/1.0 12c77b4b0 -> 963733cd0
MINOR: log4j improvements on assigned tasks and store changelog reader
Author: Guozhang Wang
Reviewers: Matthias J. Sax , Xavier Léauté
, Damian Guy , Bill Bejeck
Closes #4031 from guozhangwang/KMinor-assigned-ta
Repository: kafka
Updated Branches:
refs/heads/trunk 23a014052 -> 2427a4476
MINOR: log4j improvements on assigned tasks and store changelog reader
Author: Guozhang Wang
Reviewers: Matthias J. Sax , Xavier Léauté
, Damian Guy , Bill Bejeck
Closes #4031 from guozhangwang/KMinor-assigned-
Repository: kafka
Updated Branches:
refs/heads/1.0 aa1e4c235 -> 12c77b4b0
http://git-wip-us.apache.org/repos/asf/kafka/blob/12c77b4b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java
-
Repository: kafka
Updated Branches:
refs/heads/trunk 105ab47ed -> 23a014052
http://git-wip-us.apache.org/repos/asf/kafka/blob/23a01405/streams/src/test/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImplTest.java
---
KAFKA-5651; Follow-up: add with method to Materialized
Add a `with(Serde keySerde, Serde valSerde)` to `Materialized` for cases where
people don't care about the state store name.
Author: Damian Guy
Reviewers: Guozhang Wang , Ismael Juma ,
Matthias J. Sax
Closes #4009 from dguy/materialized
KAFKA-5651; Follow-up: add with method to Materialized
Add a `with(Serde keySerde, Serde valSerde)` to `Materialized` for cases where
people don't care about the state store name.
Author: Damian Guy
Reviewers: Guozhang Wang , Ismael Juma ,
Matthias J. Sax
Closes #4009 from dguy/materialized
Repository: kafka
Updated Branches:
refs/heads/1.0 ebeee3c8d -> aa1e4c235
KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset
It is possible for batches with sequence numbers to be in the `deque` while at
the same time the in flight batches in the `TransactionManager` are removed
Repository: kafka
Updated Branches:
refs/heads/trunk 10cd98cc8 -> 105ab47ed
KAFKA-6015; Fix NPE in RecordAccumulator after ProducerId reset
It is possible for batches with sequence numbers to be in the `deque` while at
the same time the in flight batches in the `TransactionManager` are remove
Repository: kafka
Updated Branches:
refs/heads/1.0 32ee1a879 -> ebeee3c8d
KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for
topics
Author: Manikumar Reddy
Reviewers: Rajini Sivaram , Ismael Juma
, Jason Gustafson
Closes #3924 from omkreddy/KAFKA-5547-TOPIC-AUT
Repository: kafka
Updated Branches:
refs/heads/trunk fb6ca658d -> 10cd98cc8
KAFKA-5547; Return TOPIC_AUTHORIZATION_FAILED error if no describe access for
topics
Author: Manikumar Reddy
Reviewers: Rajini Sivaram , Ismael Juma
, Jason Gustafson
Closes #3924 from omkreddy/KAFKA-5547-TOPIC-A
Repository: kafka
Updated Branches:
refs/heads/trunk 974d6fec9 -> fb6ca658d
MINOR: Allow schedule and commit in MockProcessorContext
This change allows for testing custom Processors and Transformers that call
`schedule` and `commit` using KStreamTestDriver, by _not_ throwing
`UnsupportedOper
Repository: kafka
Updated Branches:
refs/heads/1.0 b113b4bd3 -> 32ee1a879
KAFKA-5953: Register all jdbc drivers available in plugin and class paths
Author: Konstantine Karantasis
Reviewers: Randall Hauch , Ewen Cheslack-Postava
Closes #4030 from
kkonstantine/KAFKA-5953-Connect-classloade
Repository: kafka
Updated Branches:
refs/heads/trunk 196bcfca0 -> 974d6fec9
KAFKA-5953: Register all jdbc drivers available in plugin and class paths
Author: Konstantine Karantasis
Reviewers: Randall Hauch , Ewen Cheslack-Postava
Closes #4030 from
kkonstantine/KAFKA-5953-Connect-classloa
Repository: kafka-site
Updated Branches:
refs/heads/asf-site 3dafcaad2 -> 450fdd86e
Adding google tracking file for youtube metrics
guozhangwang dguy Please review this. Thanks!!
Author: Manjula K
Reviewers: Damian Guy
Closes #91 from manjuapu/asf-site
Project: http://git-wip-us.apache.
21 matches
Mail list logo