Edward J. Yoon
Arun C Murthy
Vinod Kumar Vavilapalli
Matthias J. Sax
Jarek Jarcec Cecho
mail # user
mail # dev
last 7 days (1)
last 30 days (3)
last 90 days (11)
last 6 months (29)
last 9 months (221)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[KAFKA-7144] Kafka Streams doesn't properly balance partition assignment
...Kafka Streams doesn't always spread the tasks across all available instances/threadsI have a topology which consumes a single partition topic and goes .through() a 12 partition topic. The ma...
, 2018-07-11, 06:00
[DISCUSS] KIP-325: Extend Consumer Group Command to Show Beginning Offsets
- [mail # dev]
...The “Motivation” section of the KIP says that the starting offset will be useful but doesn’t say why. Can you add a use-case or two to describe how it will be useful?In our case (see https:/...
, 2018-06-28, 04:13
[KAFKA-4682] Committed offsets should not be deleted if a consumer is still active (KIP-211)
...Kafka will delete committed offsets that are older than offsets.retention.minutesIf there is an active consumer on a low traffic partition, it is possible that Kafka will delete the committe...
, 2018-06-27, 23:00
[KAFKA-5952] Refactor Consumer Fetcher metrics
, 2018-06-11, 14:09
[KAFKA-5951] Autogenerate Producer RecordAccumulator metrics
, 2018-06-11, 13:26
[KAFKA-6312] Add documentation about kafka-consumer-groups.sh's ability to set/change offsets
...KIP-122 added the ability for kafka-consumer-groups.sh to reset/change consumer offsets, at a fine grained level.There is documentation on it in the kafka-consumer-groups.sh usage text. Ther...
, 2018-06-11, 07:04
kafka ack=all and min-isr
- [mail # dev]
...I wrote a blog post on min.isr that explains it in more detail:https://logallthethings.com/2016/07/11/min-insync-replicas-what-does-it-actually-do/The post is 2 years old, but I think it's s...
, 2018-06-08, 18:13
[KAFKA-6054] ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1
...KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-268%3A+Simplify+Kafka+Streams+Rebalance+Metadata+UpgradeWe upgraded an app from kafka-streams 0.10.0.0 to 0.10.2.1. We did a rollin...
, 2018-06-07, 19:15
[KAFKA-6967] TopologyTestDriver does not allow pre-populating state stores that have change logging
...TopologyTestDriver does not allow pre-populating a state store that has logging enabled. If you try to do it, you will get the following error message: java.lang.IllegalStateException: This ...
, 2018-06-06, 22:18
[KAFKA-6970] Kafka streams lets the user call init() and close() on a state store, when inside Processors
...When using a state store within Transform (and Processor and TransformValues), the user is able to call init() and close() on the state stores. Those APIs should only be called by kafka stre...
, 2018-05-31, 22:20
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by