RE: Messages lost after broker failure

are currently trying to reproduce this without luck, do you perhaps have a scenario in mind that could cause such behavior? Thank you, Aleksandar Bircakovic -Original Message- From: Aleksandar Bircakovic [mailto:a.bircako...@levi9.com] Sent: Wednesday, April 5, 2017 5:26 PM To: dev

RE: Messages lost after broker failure

few days, is it possible that producer gets stuck and sends some messages with really big latency after many unsuccessful retries? Many thanks, Aleksandar Bircakovic -Original Message- From: Jagadish Venkatraman [mailto:jagadish1...@gmail.com] Sent: Tuesday, April 4, 2017 6:31 PM To: dev@samz

Messages lost after broker failure

) for [topic_name,60]. Attempting to use Kafka's auto.offset.reset setting. This can result in data loss if processing continues. Any help and suggestion will be appreciated. Thanks, Aleksandar Bircakovic

Re: Review Request 41874: SAMZA-837: Support Gradle 2.9

1874/#review112705 --- On Jan. 4, 2016, 9:59 a.m., Aleksandar Bircakovic wrote: > > --- > This is an automatically generated e-mail. To reply, visit: > http

Review Request 41874: SAMZA-837: Support Gradle 2.9

, Aleksandar Bircakovic

Review Request 40857: SAMZA 826 Fix string format issue with log message in ContainerUtil

27;%s' replaced with '{}' Diffs - samza-yarn/src/main/java/org/apache/samza/job/yarn/ContainerUtil.java 1fb6a5f Diff: https://reviews.apache.org/r/40857/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 37994: SAMZA 368 AM UI should show failed container information

Thanks, Aleksandar Bircakovic

Review Request 39130: SAMZA-791 KafkaSystemFactory narrows return types

return types for methods in KafkaSystemFactory. Diffs - samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala d84bf06 Diff: https://reviews.apache.org/r/39130/diff/ Testing --- ./gradlew clean build Thanks, Aleksandar Bircakovic

Re: Review Request 37604: SAMZA-760 Samza Container should catch Throwables instead of just catching Exceptions

37604/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 37604: SAMZA-760 Samza Container should catch Throwables instead of just catching Exceptions

ply, visit: https://reviews.apache.org/r/37604/#review101272 --- On Aug. 25, 2015, 11:48 a.m., Aleksandar Bircakovic wrote: > > --- > This is an automatically generated e-mail.

Review Request 38668: SAMZA-776 building instructions have bad URL - http instead of https

/startup/download/index.md ee05714 Diff: https://reviews.apache.org/r/38668/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 38049: SAMZA-769 Replace deprecated method call and fix warnings

/TestCoordinatorStreamWriter.java 4eaaec2 samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java a18d8e0 Diff: https://reviews.apache.org/r/38049/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 38180: SAMZA-436 Update RocksDB KV's putAll to use write batch

is now used inside RocksDB putAll implementation instead of put sequence. Diffs - samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala a423f7b Diff: https://reviews.apache.org/r/38180/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 37536: SAMZA-710 Update WebServlet and RestServlet to read coordinatorStream information

/ApplicationMasterRestServlet.scala 09f4dc3 samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala 7fd5122 Diff: https://reviews.apache.org/r/37536/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 38049: SAMZA-769 Replace deprecated method call and fix warnings

/LoggingEventJsonSerde.java a18d8e0 Diff: https://reviews.apache.org/r/38049/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 38043: SAMZA-768 Update the downloading link for the source code

downloading links for the source code. Diffs - docs/startup/download/index.md 2f4bf2c Diff: https://reviews.apache.org/r/38043/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 37994: SAMZA 368 AM UI should show failed container information

/org/apache/samza/job/yarn/SamzaAppMasterTaskManager.scala 1743c86 Diff: https://reviews.apache.org/r/37994/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 37795: SAMZA-549: Rat shouldn't fail unlicensed files on build

just warn about unlicensed files, build will not fail. Diffs - gradle/rat.gradle 9cbc7c7 Diff: https://reviews.apache.org/r/37795/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 37604: SAMZA-760 Samza Container should catch Throwables instead of just catching Exceptions

s. Diffs (updated) - samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala 85b012b samza-core/src/test/scala/org/apache/samza/container/TestSamzaContainer.scala 4db6d5c Diff: https://reviews.apache.org/r/37604/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 37536: SAMZA-710 Update WebServlet and RestServlet to read coordinatorStream information

mza/webapp/ApplicationMasterRestServlet.scala 09f4dc3 samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala 7fd5122 Diff: https://reviews.apache.org/r/37536/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 37604: SAMZA-760 Samza Container should catch Throwables instead of just catching Exceptions

a 85b012b Diff: https://reviews.apache.org/r/37604/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 37536: SAMZA-710 Update WebServlet and RestServlet to read coordinatorStream information

samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala 09f4dc3 samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala 7fd5122 Diff: https://reviews.apache.org/r/37536/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 37521: SAMZA-737 property name stores.store-name.changelog.topic-level-property is not effective

: https://reviews.apache.org/r/37521/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 35918: SAMZA-709 Monitoring page for REST API and the dashboard

/ Testing --- File Attachments (updated) samza-am-dashboard.png https://reviews.apache.org/media/uploaded/files/2015/07/02/2b557ea4-5718-48a9-a619-78931fdc30d7__samza-am-dashboard.png Thanks, Aleksandar Bircakovic

Re: Review Request 35918: SAMZA-709 Monitoring page for REST API and the dashboard

- docs/learn/documentation/versioned/index.html e1b9f2d docs/learn/documentation/versioned/jobs/reprocessing.md 28d9925 docs/learn/documentation/versioned/jobs/web-ui-rest-api.md PRE-CREATION Diff: https://reviews.apache.org/r/35918/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 35918: Monitoring page for REST API and the dashboard

/documentation/versioned/jobs/web-ui-rest-api.md PRE-CREATION Diff: https://reviews.apache.org/r/35918/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 35601: SAMZA-418 Additional information on AM web ui

added to the table on AM web ui. Diffs (updated) - samza-yarn/src/main/less/main.less a0a6785 samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml a874b0e Diff: https://reviews.apache.org/r/35601/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 35606: SAMZA-716 One Link in Spark Streaming and Samza comparison page is broken

;post" is now pointing to the correct link. Diffs - docs/learn/documentation/versioned/comparisons/spark-streaming.md e1ccc3e Diff: https://reviews.apache.org/r/35606/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 35601: SAMZA-418 Additional information on AM web ui

/resources/scalate/WEB-INF/views/index.scaml a874b0e Diff: https://reviews.apache.org/r/35601/diff/ Testing --- Thanks, Aleksandar Bircakovic

Re: Review Request 35348: SAMZA-707 Remove dependency on samza-serializers in the samza.apache.org/startup/download page

. Diffs (updated) - docs/startup/download/index.md 37f948b Diff: https://reviews.apache.org/r/35348/diff/ Testing --- Thanks, Aleksandar Bircakovic

Review Request 35348: SAMZA-707 Remove dependency on samza-serializers in the samza.apache.org/startup/download page

described in [SAMZA-707](https://issues.apache.org/jira/browse/SAMZA-707) removed dependency samza-serializers_2.10 in index.md. Diffs - docs/startup/download/index.md 37f948b Diff: https://reviews.apache.org/r/35348/diff/ Testing --- Thanks, Aleksandar Bircakovic