Repository: kafka
Updated Branches:
refs/heads/trunk 402aa093d -> 7c988a3c8
KAFKA-5330: Use per-task converters in Connect
Instead of sharing the same converter instance within the worker, use a
converter per task.
More details:
- https://github.com/confluentinc/schema-registry/issues/514
-
Repository: kafka
Updated Branches:
refs/heads/trunk 36afd1095 -> 402aa093d
KAFKA-5937: Improve ProcessorStateManager exception handling
Author: Matthias J. Sax
Reviewers: Ted Yu , Damian Guy ,
Guozhang Wang
Repository: kafka-site
Updated Branches:
refs/heads/asf-site a872ac8a1 -> b818b7b0c
Line logo to Powered-by page + minor edits to styles +google webmaster file
dguy guozhangwang Can you please review this PR?
Author: Manjula K
Reviewers: Guozhang Wang
Repository: kafka
Updated Branches:
refs/heads/trunk ea533f0c5 -> 36afd1095
MINOR: Adding LINE corp logo to streams page
Author: Manjula K
Author: manjuapu
Reviewers: Guozhang Wang
Closes #3940 from
Repository: kafka
Updated Branches:
refs/heads/trunk 690575ec4 -> ea533f0c5
KAFKA-5913; Add hasOffset() and hasTimestamp() methods to RecordMetadata
These methods help users check for cases in which this metadata was not
returned by the broker (e.g. in the case of acks=0 or a duplicate error
Repository: kafka
Updated Branches:
refs/heads/trunk c8c6ab632 -> 690575ec4
MINOR: Follow-up improvements on top of KAFKA-5793
Simplified the condition in Sender#failBatch()
Added log in TransactionManager#updateLastAckedOffset()
Author: tedyu
Reviewers: Jason
Repository: kafka
Updated Branches:
refs/heads/trunk afaaea809 -> c8c6ab632
KAFKA-5735; KIP-190: Handle client-ids consistently
Developed with edoardocomar
Author: Mickael Maison
Reviewers: Edoardo Comar , Rajini Sivaram
Repository: kafka
Updated Branches:
refs/heads/trunk a553764c8 -> afaaea809
KAFKA-5954; Correct Connect REST API system test
Author: Randall Hauch
Reviewers: tedyu , Ismael Juma
Closes #3934 from rhauch/kafka-5954
Project:
Repository: kafka
Updated Branches:
refs/heads/trunk 96ba21e0d -> a553764c8
KAFKA-5856; AdminClient.createPartitions() follow-up (KIP-195)
- Remove DelayedCreatePartitions to reduce code duplication
- Avoid unnecessary ZK calls (call it once per request instead
of once per topic, if possible)
Repository: kafka
Updated Branches:
refs/heads/trunk f29391c49 -> 96ba21e0d
KAFKA-5947; Handle authentication failure in admin client, txn producer
1. Raise AuthenticationException for authentication failures in admin client
2. Handle AuthenticationException as a fatal error for transactional
Repository: kafka
Updated Branches:
refs/heads/trunk a2da064cb -> f29391c49
MINOR: add upgrade note for KIP-173 topic configs
Author: Damian Guy
Reviewers: Matthias J. Sax , Guozhang Wang
Closes #3921 from
KAFKA-5922: Add SessionWindowedKStream
Add `SessionWindowedKStream` and implementation. Deprecate existing
`SessionWindow` `aggregate` methods on `KGroupedStream`
Author: Damian Guy
Reviewers: Bill Bejeck , Matthias J. Sax
,
Repository: kafka
Updated Branches:
refs/heads/trunk 5f6393f9b -> b12ba240e
MINOR: Fix testUniqueErrorCodes unit test failure
Error code collision due to incorrect merge
conflict resolution after 2 PRs were merged in
quick succession.
Author: James Cheng
Reviewers:
13 matches
Mail list logo