GitHub user shivsantham opened a pull request:
https://github.com/apache/kafka/pull/3988
KAFKA-5967 Ineffective check of negative value in CompositeReadOnlyKeâ¦
package name: org.apache.kafka.streams.state.internals
Minor change to approximateNumEntries() method in
GitHub user shivsantham opened a pull request:
https://github.com/apache/kafka/pull/4021
KAFKA-5972 Flatten SMT does not work with null values
A bug in Flatten SMT while doing tests with different SMTs that are
provided out-of-box. Flatten SMT does not work as expected with
GitHub user shivsantham opened a pull request:
https://github.com/apache/kafka/pull/4041
KAFKA-6023 ThreadCache#sizeBytes() should check overflow
long sizeBytes() {
long sizeInBytes = 0;
for (final NamedCache namedCache : caches.values
GitHub user shivsantham opened a pull request:
https://github.com/apache/kafka/pull/4109
KAFKA-6024 - Move validation in KafkaConsumer ahead of acquireAndEnsuâ¦
In several methods, parameter validation is done after calling
acquireAndEnsureOpen() in Kafka Consumer
GitHub user shivsantham opened a pull request:
https://github.com/apache/kafka/pull/4305
KAFKA-6318: StreamsResetter should return non-zero return code on error
If users specify a non-existing topic as input parameter, StreamsResetter
only prints out an error message that the topic
