clear query| facets| time Search criteria: .   Results from 31 to 40 from 15402 (0.0s).
Loading phrases to help you
refine your search...
[SAMZA-1714] Creating shared context factory for shared context objects - Samza - [issue]
...Currently, ContextManager only provides a single scope, single object shared context in the high-level API:public interface ContextManager {   public void init(Config config, TaskC...
http://issues.apache.org/jira/browse/SAMZA-1714    Author: Yi Pan , 2018-10-10, 22:34
[SAMZA-1946] Problem with Race between TimerListenener initialization and timers fired from init() - Samza - [issue]
...There are use cases where a Task reads from a rocksDB table in its init and sets timers.The problem is the TimerListener is initialized later in the task-initialization flow. This causes pro...
http://issues.apache.org/jira/browse/SAMZA-1946    Author: Rayman , 2018-10-10, 17:21
[SAMZA-1912] improve code style for KafkaSystemConsumer(Proxy) and KafkaAdminClient - Samza - [issue]
...These are some code style improvements from PR #624:1. KafkaSystemConsumer and KafkaConsumerProxy:LOG.info("{}: Created KafkaConsumerProxy {} ", this, proxy);Would prefer to log everything i...
http://issues.apache.org/jira/browse/SAMZA-1912    Author: Boris Shkolnik , 2018-10-10, 00:16
[SAMZA-1921] Upgrade SamzaKafkaSystemAdmin to use latest AdminClient - Samza - [issue]
...Currently it uses kafka.admin.AdminClient, whis is old and soon to be deprecated version. We need to move to org.apache.kafka.clients.admin.AdminClient (which uses Java).Among other things, ...
http://issues.apache.org/jira/browse/SAMZA-1921    Author: Boris Shkolnik , 2018-10-09, 23:48
[SAMZA-1905] Create markdown for case study - part 1 - Samza - [issue]
...As per subject, it will include - Optimizely - Redfin - TripAdvisor...
http://issues.apache.org/jira/browse/SAMZA-1905    Author: Wei Song , 2018-10-09, 22:56
[SAMZA-1783] Add Log4j2 functionality in Samza - Samza - [issue]
http://issues.apache.org/jira/browse/SAMZA-1783    Author: Pawas Chhokra , 2018-10-09, 20:52
[SAMZA-1793] Upgrade to recent API for kafka consumer / producer. - Samza - [issue]
...Kafka consumer:  1.  Samza currently uses SimpleConsumer to consume messages from the KafkaBroker. However, the SimpleConsumer API is deprecated and is slated to be removed in future ka...
http://issues.apache.org/jira/browse/SAMZA-1793    Author: Shanthoosh Venkataraman , 2018-10-09, 19:16
[SAMZA-1945] get rid of deleteMessageCalled from KafkaSystemAdmin - Samza - [issue]
...this member should not be in the class. See if we can change the test to avoid using this member var....
http://issues.apache.org/jira/browse/SAMZA-1945    Author: Boris Shkolnik , 2018-10-09, 19:16
[SAMZA-1944] refactor KafkaSystemAdmin not to keep Coordinator/Changelog/Intermediate streams info. - Samza - [issue]
...Should be moved somewhere outside of this class....
http://issues.apache.org/jira/browse/SAMZA-1944    Author: Boris Shkolnik , 2018-10-09, 19:00
[SAMZA-1943] get rid of ExtendedSystemAdmin - Samza - [issue]
...consider changing the api from Map<String, SystemStreamMetadata> getSystemStreamPartitionCountstoMap<String, Integer> getSystemStreamPartitionCounts   ...
http://issues.apache.org/jira/browse/SAMZA-1943    Author: Boris Shkolnik , 2018-10-09, 18:48