Extending KStream DSL in applications

Hello devs, I'd like to be able to create my own KTableProcessorSupplier implementation in a Kafka Streams application, but it's currently not possible without the use of reflection due to KTableImpl's valueGetterSupplier & enableSendingOldValues methods being package-local. Would there be any op

Suppressing redundant KTable forwards

Hey all, I'd like to contribute a new KTable API that would allow for the suppression of redundant KTable forwards, and I'd like to solicit feedback before I put together a patch. A typical use-case of this API would be that you're using mapValues to pluck a subset of data out of a topic, but you

[jira] [Updated] (KAFKA-4476) Kafka Streams gets stuck if metadata is missing

[ https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4476: --- Status: Patch Available (was: In Progress) > Kafka Streams gets stuck if metadata is missing

[jira] [Commented] (KAFKA-4476) Kafka Streams gets stuck if metadata is missing

[ https://issues.apache.org/jira/browse/KAFKA-4476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15717780#comment-15717780 ] ASF GitHub Bot commented on KAFKA-4476: --- GitHub user mjsax opened a pull request:

[GitHub] kafka pull request #2209: KAFKA-4476: Kafka Streams gets stuck if metadata i...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2209 KAFKA-4476: Kafka Streams gets stuck if metadata is missing - break loop in StreamPartitionAssigner.assign() in case partition metadata is missing - fit state transition issue (follow up to KAFK

Build failed in Jenkins: kafka-trunk-jdk7 #1728

See Changes: [jason] KAFKA-4483; Fix NPE in `Log` constructor if log level is INFO or finer -- [...truncated 14212 lines...] org.apache.kafka.streams.processor.TopologyBuilderTest > shouldAssoc

[GitHub] kafka pull request #2199: HOTFIX: Temporary suspension of 2 tests

Github user enothereska closed the pull request at: https://github.com/apache/kafka/pull/2199 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is