thread 'main' panicked at 'FIXME: Error(Kafka(OffsetOutOfRange), State { next_error: None, backtrace: Some(stack backtrace:
   0: error_chain::make_backtrace::ha2000222ff02d863 (0x55baff750058)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/error-chain-0.10.0/src/lib.rs:417
   1: <error_chain::State as core::default::Default>::default::h3b89b4160ec454d7 (0x55baff7500e6)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/error-chain-0.10.0/src/lib.rs:504
   2: kafka::error::Error::from_kind::h514a7eba85348c26 (0x55baff73d247)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/<::error_chain::error_chain::error_chain_processed macros>:52
      <kafka::error::Error as core::convert::From<kafka::error::ErrorKind>>::from::h224c04e29b15a58a
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/error.rs:11
      <T as core::convert::Into<U>>::into::h34fe063a4f1adb82
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libcore/convert.rs:540
      kafka::protocol::<impl kafka::error::Error>::from_protocol::{{closure}}::h7c72be7474747c48
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/mod.rs:101
      core::option::Option<T>::map::h32ee7633acf2e056
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libcore/option.rs:414
      kafka::protocol::<impl kafka::error::Error>::from_protocol::h221076dee8877a6c
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/mod.rs:101
      kafka::protocol::fetch::Partition::read::h91aca16ce9084f55
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:288
      kafka::protocol::fetch::Topic::read::h2e45a713c5d793a6
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:240
      kafka::protocol::fetch::Response::from_vec::hf603d7f59bf02274
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:199
      <kafka::protocol::fetch::ResponseParser as kafka::protocol::ResponseParser>::parse::ha4927ff966dc34a7
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:152
   3: kafka::client::__z_get_response::h78d372202076784f (0x55baff745dab)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1670
      kafka::client::__z_send_receive::h251caa43c5730d2b
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1648
      kafka::client::__fetch_messages::h408130c5837b15b0
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1531
   4: kafka::client::KafkaClient::fetch_messages::hc2fb6899b61177cf (0x55baff71653d)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1068
      joseph::client::ReceiverInner::fetch_messages::h145fb3c3b5173bfa
             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:307
      joseph::client::ReceiverInner::retrieve_messages::ha1441d4f51180a3f
             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:374
      joseph::client::ReceiverInner::try_receive_next::ha7417195a6909034
             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:400
   5: <joseph::client::SyncReceiver as core::iter::traits::iterator::Iterator>::next::hc583ce2a142740f3 (0x55baff717a5c)
             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:449
   6: <futures::stream::iter_result::IterResult<I> as futures::stream::Stream>::poll::ha8877522f6ab1a7b (0x55baff6e9bc5)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/iter_result.rs:45
      <futures::stream::then::Then<S,F,U> as futures::stream::Stream>::poll::h8a090774c8d219ed
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/then.rs:60
   7: <futures::stream::map::Map<S,F> as futures::stream::Stream>::poll::h2b5ba717a7fdb6c9 (0x55baff6f700b)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/map.rs:78
   8: <futures::stream::then::Then<S,F,U> as futures::stream::Stream>::poll::h82017d2070dc3d13 (0x55baff6e9430)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/then.rs:60
   9: <futures::stream::filter_map::FilterMap<S,F> as futures::stream::Stream>::poll::h03003e9d85bcf88e (0x55baff6cdf40)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/filter_map.rs:79
      <futures::stream::for_each::ForEach<S,F,U> as futures::future::Future>::poll::h91908c2dd33e7778
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/for_each.rs:45
      futures::future::join::MaybeDone<A>::poll::ha8d41a1abdca842d
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/join.rs:153
      <futures::future::join::Join<A,B> as futures::future::Future>::poll::h346e012e78aee4b7
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/join.rs:75
  10: <futures::future::map::Map<A,F> as futures::future::Future>::poll::h0b03915de077a749 (0x55baff6e9309)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/map.rs:30
  11: <alloc::boxed::Box<F> as futures::future::Future>::poll::h390832f00857f96b (0x55baff647bf2)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/mod.rs:113
      futures::task_impl::Spawn<T>::poll_future_notify::{{closure}}::hb108f322c59c74f4
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:329
      futures::task_impl::Spawn<T>::enter::{{closure}}::hab1f1e3727ef391b
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:399
      futures::task_impl::std::set::h48d1e90ce6c24774
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/std/mod.rs:83
  12: futures::task_impl::Spawn<T>::enter::h7fe5c4562dfe00c2 (0x55baff62997b)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:399
      futures::task_impl::Spawn<T>::poll_fn_notify::hb93a5ef4e7bded27
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:291
      futures::task_impl::Spawn<T>::poll_future_notify::hd65532aa3d95aadf
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:329
      tokio_current_thread::scheduler::Scheduled<U>::tick::hd96ec1c2c1080936
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:351
      tokio_current_thread::scheduler::Scheduler<U>::tick::{{closure}}::h436d9cf9d4e22532
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:330
      tokio_current_thread::Borrow<U>::enter::{{closure}}::{{closure}}::h9d58d47ca66f749b
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:788
      tokio_current_thread::CurrentRunner::set_spawn::hdf799f550f73abcf
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:825
  13: tokio_current_thread::Borrow<U>::enter::{{closure}}::h4e305018bde47d74 (0x55baff62c589)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:788
      std::thread::local::LocalKey<T>::try_with::h7c13a0f8caf85691
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
      std::thread::local::LocalKey<T>::with::he34e89614c01a736
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
      tokio_current_thread::Borrow<U>::enter::h908592d99d15f8cf
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:786
      tokio_current_thread::scheduler::Scheduler<U>::tick::h5f7604afcd66e65d
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:330
  14: tokio_current_thread::Entered<P>::tick::h8c39a26ae4d4a01b (0x55baff62ad52)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:612
      tokio_current_thread::Entered<P>::block_on::hb246221f850448cf
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:502
  15: current_thread_runtime::runtime::Runtime<P>::block_on::{{closure}}::heca65fc459f58a21 (0x55baff66b388)
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:191
      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::{{closure}}::{{closure}}::{{closure}}::h0d2b347f3faf7626
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:232
      tokio_executor::global::with_default::{{closure}}::h20170820f4d95a61
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-executor-0.1.7/src/global.rs:209
      std::thread::local::LocalKey<T>::try_with::h51f506c0055640de
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
      std::thread::local::LocalKey<T>::with::h5f7404eecf72d383
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  16: tokio_executor::global::with_default::hf8a79868863bdfdd (0x55baff66d0ee)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-executor-0.1.7/src/global.rs:178
      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::{{closure}}::{{closure}}::h86762f63fd9123e2
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:230
      tokio_timer::timer::handle::with_default::{{closure}}::hc2420b4a67446037
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/timer/handle.rs:101
      std::thread::local::LocalKey<T>::try_with::h1960a4a875b1df9f
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
      std::thread::local::LocalKey<T>::with::h8b18a8df2aa8c7f4
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  17: tokio_timer::timer::handle::with_default::he8b9dd34ecef9910 (0x55baff66fded)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/timer/handle.rs:84
      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::{{closure}}::h69710e1ff87e6a48
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:223
      tokio_timer::clock::clock::with_default::{{closure}}::h20c763be8a0982fc
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/clock/clock.rs:137
      std::thread::local::LocalKey<T>::try_with::h64893243af293f8e
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
      std::thread::local::LocalKey<T>::with::hc4430a1ff8a463f7
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  18: tokio_timer::clock::clock::with_default::h1259f3c7d0128014 (0x55baff671c40)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/clock/clock.rs:117
      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::h10e4b109e3771faa
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:222
      tokio_reactor::with_default::{{closure}}::hdc789169313374b2
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-reactor-0.1.9/src/lib.rs:237
      std::thread::local::LocalKey<T>::try_with::ha9dc6f8a1da839e2
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
      std::thread::local::LocalKey<T>::with::hdc828a3cfe592f1a
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  19: tokio_reactor::with_default::hae0450cfba60a54d (0x55baff62d6a8)
             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-reactor-0.1.9/src/lib.rs:217
      current_thread_runtime::runtime::Runtime<P>::enter::ha72b7b1d4e321e79
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:221
      current_thread_runtime::runtime::Runtime<P>::block_on::hb4f3c889b39420c5
             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:189
  20: topology::services::control_gate::run_internal::ha9161d536178ec0e (0x55baff689467)
             at /builds/exchange/hft/core/topology/src/services.rs:4
      topology::services::control_gate::run::h0fb5bba3ed7f91a0
             at /builds/exchange/hft/core/topology/src/services.rs:4
  21: control_gate::main::hbc30353c1d770465 (0x55baff655c8b)
             at control_gate/src/main.rs:7
  22: std::rt::lang_start::{{closure}}::hf50ec9500a2ac23b (0x55baff656b33)
             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/rt.rs:64
  23: {{closure}} (0x55baff85f7d3)
             at src/libstd/rt.rs:49
      do_call<closure,i32>
             at src/libstd/panicking.rs:293
  24: __rust_maybe_catch_panic (0x55baff863e6a)
             at src/libpanic_unwind/lib.rs:87
  25: try<i32,closure> (0x55baff8602dd)
             at src/libstd/panicking.rs:272
      catch_unwind<closure,i32>
             at src/libstd/panic.rs:388
      lang_start_internal
             at src/libstd/rt.rs:48
  26: main (0x55baff656268)
  27: __libc_start_main (0x7f31900ed3d5)
  28: <unknown> (0x55baff62535b)
  29: <unknown> (0x0)) })', src/libcore/result.rs:997:5
stack backtrace:
   0: std::sys::unix::backtrace::tracing::imp::unwind_backtrace
             at src/libstd/sys/unix/backtrace/tracing/gcc_s.rs:39
   1: std::sys_common::backtrace::_print
             at src/libstd/sys_common/backtrace.rs:71
   2: std::panicking::default_hook::{{closure}}
             at src/libstd/sys_common/backtrace.rs:59
             at src/libstd/panicking.rs:197
   3: std::panicking::default_hook
             at src/libstd/panicking.rs:211
   4: base::logger::panic_hook::decorate::{{closure}}
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/liballoc/boxed.rs:716
             at base/src/logger/panic_hook.rs:97
   5: std::panicking::rust_panic_with_hook
             at src/libstd/panicking.rs:478
   6: std::panicking::continue_panic_fmt
             at src/libstd/panicking.rs:381
   7: rust_begin_unwind
             at src/libstd/panicking.rs:308
   8: core::panicking::panic_fmt
             at src/libcore/panicking.rs:85
   9: core::result::unwrap_failed
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libcore/macros.rs:18
  10: joseph::client::ReceiverInner::try_receive_next
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libcore/result.rs:825
             at ./root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:335
             at ./root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:374
             at ./root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:400
  11: <joseph::client::SyncReceiver as core::iter::traits::iterator::Iterator>::next
             at ./root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:449
  12: <futures::stream::then::Then<S,F,U> as futures::stream::Stream>::poll
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/iter_result.rs:45
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/then.rs:60
  13: <futures::stream::map::Map<S,F> as futures::stream::Stream>::poll
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/map.rs:78
  14: <futures::stream::then::Then<S,F,U> as futures::stream::Stream>::poll
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/then.rs:60
  15: <futures::future::join::Join<A,B> as futures::future::Future>::poll
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/filter_map.rs:79
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/for_each.rs:45
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/join.rs:153
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/join.rs:75
  16: <futures::future::map::Map<A,F> as futures::future::Future>::poll
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/map.rs:30
  17: futures::task_impl::std::set
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/mod.rs:113
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:329
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:399
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/std/mod.rs:83
  18: tokio_current_thread::CurrentRunner::set_spawn
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:399
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:291
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:329
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:351
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:330
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:788
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:825
  19: tokio_current_thread::scheduler::Scheduler<U>::tick
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:788
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:786
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:330
  20: tokio_current_thread::Entered<P>::block_on
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:612
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:502
  21: std::thread::local::LocalKey<T>::with
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:191
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:232
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-executor-0.1.7/src/global.rs:209
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  22: std::thread::local::LocalKey<T>::with
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-executor-0.1.7/src/global.rs:178
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:230
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/timer/handle.rs:101
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  23: std::thread::local::LocalKey<T>::with
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/timer/handle.rs:84
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:223
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/clock/clock.rs:137
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  24: std::thread::local::LocalKey<T>::with
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/clock/clock.rs:117
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:222
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-reactor-0.1.9/src/lib.rs:237
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245
  25: current_thread_runtime::runtime::Runtime<P>::block_on
             at ./root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-reactor-0.1.9/src/lib.rs:217
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:221
             at ./root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:189
  26: topology::services::control_gate::run
             at ./builds/exchange/hft/core/topology/src/services.rs:4
             at ./builds/exchange/hft/core/topology/src/services.rs:4
  27: control_gate::main
             at control_gate/src/main.rs:7
  28: std::rt::lang_start::{{closure}}
             at ./rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/rt.rs:64
  29: std::panicking::try::do_call
             at src/libstd/rt.rs:49
             at src/libstd/panicking.rs:293
  30: __rust_maybe_catch_panic
             at src/libpanic_unwind/lib.rs:87
  31: std::rt::lang_start_internal
             at src/libstd/panicking.rs:272
             at src/libstd/panic.rs:388
             at src/libstd/rt.rs:48
  32: main
  33: __libc_start_main
  34: <unknown>
2019-07-16 16:15:28.294057856 CRIT: Panic, file = "src/libcore/result.rs", line = 997, message = "FIXME: Error(Kafka(OffsetOutOfRange), State { next_error: None, backtrace: Some(stack backtrace:\n   0: error_chain::make_backtrace::ha2000222ff02d863 (0x55baff750058)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/error-chain-0.10.0/src/lib.rs:417\n   1: <error_chain::State as core::default::Default>::default::h3b89b4160ec454d7 (0x55baff7500e6)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/error-chain-0.10.0/src/lib.rs:504\n   2: kafka::error::Error::from_kind::h514a7eba85348c26 (0x55baff73d247)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/<::error_chain::error_chain::error_chain_processed macros>:52\n      <kafka::error::Error as core::convert::From<kafka::error::ErrorKind>>::from::h224c04e29b15a58a\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/error.rs:11\n      <T as core::convert::Into<U>>::into::h34fe063a4f1adb82\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libcore/convert.rs:540\n      kafka::protocol::<impl kafka::error::Error>::from_protocol::{{closure}}::h7c72be7474747c48\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/mod.rs:101\n      core::option::Option<T>::map::h32ee7633acf2e056\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libcore/option.rs:414\n      kafka::protocol::<impl kafka::error::Error>::from_protocol::h221076dee8877a6c\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/mod.rs:101\n      kafka::protocol::fetch::Partition::read::h91aca16ce9084f55\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:288\n      kafka::protocol::fetch::Topic::read::h2e45a713c5d793a6\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:240\n      kafka::protocol::fetch::Response::from_vec::hf603d7f59bf02274\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:199\n      <kafka::protocol::fetch::ResponseParser as kafka::protocol::ResponseParser>::parse::ha4927ff966dc34a7\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/protocol/fetch.rs:152\n   3: kafka::client::__z_get_response::h78d372202076784f (0x55baff745dab)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1670\n      kafka::client::__z_send_receive::h251caa43c5730d2b\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1648\n      kafka::client::__fetch_messages::h408130c5837b15b0\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1531\n   4: kafka::client::KafkaClient::fetch_messages::hc2fb6899b61177cf (0x55baff71653d)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/kafka-0.7.0/src/client/mod.rs:1068\n      joseph::client::ReceiverInner::fetch_messages::h145fb3c3b5173bfa\n             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:307\n      joseph::client::ReceiverInner::retrieve_messages::ha1441d4f51180a3f\n             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:374\n      joseph::client::ReceiverInner::try_receive_next::ha7417195a6909034\n             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:400\n   5: <joseph::client::SyncReceiver as core::iter::traits::iterator::Iterator>::next::hc583ce2a142740f3 (0x55baff717a5c)\n             at /root/.cargo/git/checkouts/joseph-9f34bdf9f29e5728/4fda54f/src/client.rs:449\n   6: <futures::stream::iter_result::IterResult<I> as futures::stream::Stream>::poll::ha8877522f6ab1a7b (0x55baff6e9bc5)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/iter_result.rs:45\n      <futures::stream::then::Then<S,F,U> as futures::stream::Stream>::poll::h8a090774c8d219ed\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/then.rs:60\n   7: <futures::stream::map::Map<S,F> as futures::stream::Stream>::poll::h2b5ba717a7fdb6c9 (0x55baff6f700b)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/map.rs:78\n   8: <futures::stream::then::Then<S,F,U> as futures::stream::Stream>::poll::h82017d2070dc3d13 (0x55baff6e9430)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/then.rs:60\n   9: <futures::stream::filter_map::FilterMap<S,F> as futures::stream::Stream>::poll::h03003e9d85bcf88e (0x55baff6cdf40)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/filter_map.rs:79\n      <futures::stream::for_each::ForEach<S,F,U> as futures::future::Future>::poll::h91908c2dd33e7778\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/stream/for_each.rs:45\n      futures::future::join::MaybeDone<A>::poll::ha8d41a1abdca842d\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/join.rs:153\n      <futures::future::join::Join<A,B> as futures::future::Future>::poll::h346e012e78aee4b7\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/join.rs:75\n  10: <futures::future::map::Map<A,F> as futures::future::Future>::poll::h0b03915de077a749 (0x55baff6e9309)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/map.rs:30\n  11: <alloc::boxed::Box<F> as futures::future::Future>::poll::h390832f00857f96b (0x55baff647bf2)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/future/mod.rs:113\n      futures::task_impl::Spawn<T>::poll_future_notify::{{closure}}::hb108f322c59c74f4\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:329\n      futures::task_impl::Spawn<T>::enter::{{closure}}::hab1f1e3727ef391b\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:399\n      futures::task_impl::std::set::h48d1e90ce6c24774\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/std/mod.rs:83\n  12: futures::task_impl::Spawn<T>::enter::h7fe5c4562dfe00c2 (0x55baff62997b)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:399\n      futures::task_impl::Spawn<T>::poll_fn_notify::hb93a5ef4e7bded27\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:291\n      futures::task_impl::Spawn<T>::poll_future_notify::hd65532aa3d95aadf\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/futures-0.1.28/src/task_impl/mod.rs:329\n      tokio_current_thread::scheduler::Scheduled<U>::tick::hd96ec1c2c1080936\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:351\n      tokio_current_thread::scheduler::Scheduler<U>::tick::{{closure}}::h436d9cf9d4e22532\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:330\n      tokio_current_thread::Borrow<U>::enter::{{closure}}::{{closure}}::h9d58d47ca66f749b\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:788\n      tokio_current_thread::CurrentRunner::set_spawn::hdf799f550f73abcf\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:825\n  13: tokio_current_thread::Borrow<U>::enter::{{closure}}::h4e305018bde47d74 (0x55baff62c589)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:788\n      std::thread::local::LocalKey<T>::try_with::h7c13a0f8caf85691\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299\n      std::thread::local::LocalKey<T>::with::he34e89614c01a736\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245\n      tokio_current_thread::Borrow<U>::enter::h908592d99d15f8cf\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:786\n      tokio_current_thread::scheduler::Scheduler<U>::tick::h5f7604afcd66e65d\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/scheduler.rs:330\n  14: tokio_current_thread::Entered<P>::tick::h8c39a26ae4d4a01b (0x55baff62ad52)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:612\n      tokio_current_thread::Entered<P>::block_on::hb246221f850448cf\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-current-thread-0.1.6/src/lib.rs:502\n  15: current_thread_runtime::runtime::Runtime<P>::block_on::{{closure}}::heca65fc459f58a21 (0x55baff66b388)\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:191\n      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::{{closure}}::{{closure}}::{{closure}}::h0d2b347f3faf7626\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:232\n      tokio_executor::global::with_default::{{closure}}::h20170820f4d95a61\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-executor-0.1.7/src/global.rs:209\n      std::thread::local::LocalKey<T>::try_with::h51f506c0055640de\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299\n      std::thread::local::LocalKey<T>::with::h5f7404eecf72d383\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245\n  16: tokio_executor::global::with_default::hf8a79868863bdfdd (0x55baff66d0ee)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-executor-0.1.7/src/global.rs:178\n      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::{{closure}}::{{closure}}::h86762f63fd9123e2\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:230\n      tokio_timer::timer::handle::with_default::{{closure}}::hc2420b4a67446037\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/timer/handle.rs:101\n      std::thread::local::LocalKey<T>::try_with::h1960a4a875b1df9f\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299\n      std::thread::local::LocalKey<T>::with::h8b18a8df2aa8c7f4\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245\n  17: tokio_timer::timer::handle::with_default::he8b9dd34ecef9910 (0x55baff66fded)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/timer/handle.rs:84\n      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::{{closure}}::h69710e1ff87e6a48\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:223\n      tokio_timer::clock::clock::with_default::{{closure}}::h20c763be8a0982fc\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/clock/clock.rs:137\n      std::thread::local::LocalKey<T>::try_with::h64893243af293f8e\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299\n      std::thread::local::LocalKey<T>::with::hc4430a1ff8a463f7\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245\n  18: tokio_timer::clock::clock::with_default::h1259f3c7d0128014 (0x55baff671c40)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-timer-0.2.11/src/clock/clock.rs:117\n      current_thread_runtime::runtime::Runtime<P>::enter::{{closure}}::h10e4b109e3771faa\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:222\n      tokio_reactor::with_default::{{closure}}::hdc789169313374b2\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-reactor-0.1.9/src/lib.rs:237\n      std::thread::local::LocalKey<T>::try_with::ha9dc6f8a1da839e2\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:299\n      std::thread::local::LocalKey<T>::with::hdc828a3cfe592f1a\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/thread/local.rs:245\n  19: tokio_reactor::with_default::hae0450cfba60a54d (0x55baff62d6a8)\n             at /root/.cargo/registry/src/github.com-1ecc6299db9ec823/tokio-reactor-0.1.9/src/lib.rs:217\n      current_thread_runtime::runtime::Runtime<P>::enter::ha72b7b1d4e321e79\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:221\n      current_thread_runtime::runtime::Runtime<P>::block_on::hb4f3c889b39420c5\n             at /root/.cargo/git/checkouts/current-thread-runtime-93f367492d2adbb6/e294fa2/src/runtime.rs:189\n  20: topology::services::control_gate::run_internal::ha9161d536178ec0e (0x55baff689467)\n             at /builds/exchange/hft/core/topology/src/services.rs:4\n      topology::services::control_gate::run::h0fb5bba3ed7f91a0\n             at /builds/exchange/hft/core/topology/src/services.rs:4\n  21: control_gate::main::hbc30353c1d770465 (0x55baff655c8b)\n             at control_gate/src/main.rs:7\n  22: std::rt::lang_start::{{closure}}::hf50ec9500a2ac23b (0x55baff656b33)\n             at /rustc/3c235d5600393dfe6c36eeed34042efad8d4f26e/src/libstd/rt.rs:64\n  23: {{closure}} (0x55baff85f7d3)\n             at src/libstd/rt.rs:49\n      do_call<closure,i32>\n             at src/libstd/panicking.rs:293\n  24: __rust_maybe_catch_panic (0x55baff863e6a)\n             at src/libpanic_unwind/lib.rs:87\n  25: try<i32,closure> (0x55baff8602dd)\n             at src/libstd/panicking.rs:272\n      catch_unwind<closure,i32>\n             at src/libstd/panic.rs:388\n      lang_start_internal\n             at src/libstd/rt.rs:48\n  26: main (0x55baff656268)\n  27: __libc_start_main (0x7f31900ed3d5)\n  28: <unknown> (0x55baff62535b)\n  29: <unknown> (0x0)) })", stack = []