GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/4309
KAFKA-4218: Enable access to key in ValueTransformer and ValueMapper
This PR is the partial implementation for KIP-149. As the discussion for
this KIP is still ongoing, I made a PR on the
Github user jeyhunkarimov closed the pull request at:
https://github.com/apache/kafka/pull/3570
---
Github user jeyhunkarimov closed the pull request at:
https://github.com/apache/kafka/pull/4149
---
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/4149
KAFKA-6126: Reduce rebalance time by not checking if created topics are
available
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3601
KAFKA-4218: Add withkey methods to KGroupedTable
This PR aims to add withKey methods to KGroupedTable interface.
This PR is part of
[KIP-149](https://cwiki.apache.org/confluence/display
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3600
KAFKA-4218 : Add withkey methods to KTable
This PR aims to add withKey methods to KTable interface.
This PR is part of
[KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP-149
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3599
KAFKA-4218: Add withkey methods to KGroupedStream
This PR aims to add withKey methods to KGroupedStream interface.
This PR is part of
[KIP-149](https://cwiki.apache.org/confluence
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3598
KAFKA-4218: Add withkey methods to KStream
This PR aims to add withKey methods to KStream interface.
This PR is part of
[KIP-149](https://cwiki.apache.org/confluence/display/KAFKA/KIP
Github user jeyhunkarimov closed the pull request at:
https://github.com/apache/kafka/pull/2946
---
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
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3570
KAFKA-4218: KIP-149, Enabling withKey interfaces in streams
This PR aims to provide key access to ValueMapper, ValueJoiner,
ValueTransformer, Initializer and Reducer interfaces. More details
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3294
KAFKA-4653: Improve test coverage of RocksDBStore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4653
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3293
KAFKA-4658: Improve test coverage InMemoryKeyValueLoggedStore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka KAFKA
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3292
KAFKA-4656: Improve test coverage of CompositeReadOnlyKeyValueStore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3291
KAFKA-4659: Improve test coverage of CachingKeyValueStore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4659
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3290
KAFKA-4655: Improve test coverage of CompositeReadOnlySessionStore
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3288
KAFKA-4661: Improve test coverage UsePreviousTimeOnInvalidTimestamp
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3109
KAFKA-4144: Allow per stream/table timestamp extractor
A follow up RP to fix
[issue](https://github.com/confluentinc/examples/commit/2cd0b87bc8a7eab0e7199fa0079db6417f0e6b63#commitcomment
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3106
KAFKA-4785: Records from internal repartitioning topics should always use
RecordMetadataTimestampExtractor
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/3047
KAFKA-5228: Revisit Streams DSL JavaDocs
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka KAFKA-5228
Alternatively
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/2946
KAFKA-4218: Enable access to key in ValueTransformer
This PR groups KAFKA-4218, KAFKA-4726 and KAFKA-3745.
You can merge this pull request into a Git repository by running:
$ git pull
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/2466
KAFKA-4144: Allow per stream/table timestamp extractor
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov/kafka KAFKA-4144
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/2420
KAFKA-4613: Treat null-key records the same way for joins and aggreations
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/jeyhunkarimov
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/2417
KAFKA-3835: Streams is creating two ProducerRecords for each send via
RecordCollector
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/1591
KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to
Deserializers
Minor changes to check null changes.
You can merge this pull request into a Git repository by running
Github user jeyhunkarimov closed the pull request at:
https://github.com/apache/kafka/pull/1569
---
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
Github user jeyhunkarimov closed the pull request at:
https://github.com/apache/kafka/pull/1585
---
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
Github user jeyhunkarimov closed the pull request at:
https://github.com/apache/kafka/pull/1586
---
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
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/1588
KAFKA-3825: Allow users to specify different types of state stores in
Streams DSL
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/1586
Kafka 3836: KStreamReduce and KTableReduce should not pass nulls to
Deserializers
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/1585
KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to
Deserializers
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
GitHub user jeyhunkarimov opened a pull request:
https://github.com/apache/kafka/pull/1569
Kafka 3836: KStreamReduce and KTableReduce should not pass nulls to
Deserializers
You can merge this pull request into a Git repository by running:
$ git pull https://github.com
31 matches
Mail list logo
