[09:45:19] SMalyshev: probably too late, but there is a parameter in kafkacat to start from "earliest" [09:45:40] sorry [09:45:40] -o Offset to start consuming from: [09:45:40] beginning | end | stored | [09:46:21] SMalyshev: so I'd to kafkacat -b kafka-jumbo1001.eqiad.wmnet -t your-topic -p partition-number -c 1 -o beginning [09:46:24] :) [09:47:30] (03CR) 10Elukey: "WOOOWWW thanks!" [analytics/refinery] - 10https://gerrit.wikimedia.org/r/527583 (https://phabricator.wikimedia.org/T229669) (owner: 10Mforns) [09:47:34] (03CR) 10Elukey: [C: 03+1] Add jar to cassandra jobs for compatibility with hive2 actions [analytics/refinery] - 10https://gerrit.wikimedia.org/r/527583 (https://phabricator.wikimedia.org/T229669) (owner: 10Mforns)