clear query| facets| time Search criteria: .   Results from 1 to 10 from 206 (0.0s).
Loading phrases to help you
refine your search...
[SAMZA-1888] minor improvements for the after commit for KafkaSystemAdmin and KafkaSystemConsumer. - Samza - [issue]
...consider documents on the following: usage of zookeeper connect, still needed for AdminClient (not for KafkaConsumer) timeout for the Kafka client buffer size for Kafka Client Create a separ...
http://issues.apache.org/jira/browse/SAMZA-1888    Author: Boris Shkolnik , 2018-10-12, 18:36
[SAMZA-1868] Refactor KafkaSystemAdmin from using SimpleConsumer - Samza - [issue]
...Convert it into using KafkaSystemConsumer.Aslo, move getClientId into KafkaConsumerConfig....
http://issues.apache.org/jira/browse/SAMZA-1868    Author: Boris Shkolnik , 2018-10-11, 21:27
[SAMZA-1934] LocalApplicationRunner fails for LegacyTaskApplication app.class - Samza - [issue]
...For legacy job we set app.class to LegacyTaskApplication.It is being run by LocalApplicationRunner and it calls ApplicationUtils to instantiate the application. When it gets LegacyTaskApplic...
http://issues.apache.org/jira/browse/SAMZA-1934    Author: Boris Shkolnik , 2018-10-11, 18:47
[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-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
[SAMZA-1906] remove ExponentialSleepStrategy from KafkaSystemAdmin code. - Samza - [issue]
...The retry is not needed anymore because the new kafka client should take care of it.refactor the following methods in KafkaSystemAdmin:getSystemStreamPartitionCountsgetSystemStreamMetadatage...
http://issues.apache.org/jira/browse/SAMZA-1906    Author: Boris Shkolnik , 2018-10-03, 22:00
[SAMZA-1936] Investigate if we can get Kafka stream high watermark without using KafkaMetrics - Samza - [issue]
...Currently we query kafka results of each call for metrics (which contains the lags), which requires client_id.Need to find out if there is a way to do it without metrics in the new client....
http://issues.apache.org/jira/browse/SAMZA-1936    Author: Boris Shkolnik , 2018-10-03, 21:52