hide the node stack in StreamTask, add PunctuationQueueTest#42
Closed
ymatsuda wants to merge 317 commits into
Closed
hide the node stack in StreamTask, add PunctuationQueueTest#42ymatsuda wants to merge 317 commits into
ymatsuda wants to merge 317 commits into
Conversation
clear interrupted status after park
simplify onPartitionsRevoked action
Allow KStreamContext.from() to have multiple topics and extend the Processor interface to include topic names; only preserve the topic name in KStreamSource and KStreamWindowed since they do not transform data yet.
…into cleanup_ingestor
clean up ingestor and stream synchronizer
Add examples of Processor and KStreamJob; add collector and coordinator to Processor.apply.
Remove SyncGroup from user facing APIs
Modify the Processor API (again)
do not clone kstream context
RecordCollector api
make the close method work
make sure Processor.close() is called at the end of task
no need for RecordCollector to know default serializers
enable default SerDe, optimize record inserts
logging exceptions
…ined together. Since the methods returned void before, this has no other impact on existing code.
…mprovement TopologyBuilder methods return the builder to allow methods to be chained together.
fix unused imports
… JAR when uploading artifacts into Maven. Without these minor changes, the stream project's test JAR is never uploaded into Maven.
Fix ProcessorJob; rename streaming to streams
Streaming build fix
Address some comments
f5ff182 to
050aade
Compare
José Armando García Sancio (jsancio)
pushed a commit
that referenced
this pull request
Sep 13, 2019
) Configure `default_tkt_enctypes` and `default_tgs_enctypes` to use `aes128-cts-hmac-sha1-96` so that tests work with Java 11 since MiniKdc doesn't support `aes128-cts-hmac-sha256-128` and `aes256-cts-hmac-sha384-192` that are enabled by default in Java 11. This is the same fix as KAFKA-7338 applied for the config used by LDAP authorizer.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
3 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Guozhang Wang (@guozhangwang)