         ))))
 
 (defn normalize-tx-tuple [values]
-  (-> values vec (update 0 (memfn getTransactionId))))
+  (-> values vec (update 0 #(-> % .getTransactionId .intValue))))
 
 (defn verify-and-reset! [expected-map emitted-map-atom]
   (let [results @emitted-map-atom]

       (tracked-wait topo-info 2)
       (println "Controlled: " @tuples)
       (println "Captured:" (-> topo-info :capturer .getResults))
       ;; check that batch tuples have been emitted for tx 1 and 2
       ;; check the outputs of all the bolts
       ;; ack the ack the first batch
       ;; check that first batch commits
       ;; ack the commit
       ;; check that third batch is emitted
       ;; ack the third batch

                        (.createTopology builder)))
       (submit-local-topology (:nimbus cluster)
                              "transactional-test"
                              {TOPOLOGY-MAX-SPOUT-PENDING 2}
                              (:topology topo-info))

       (bind ack-tx! (fn [txid]
                       (let [[to-ack not-to-ack] (separate
                                                  #(-> %
                                                       (.getValue 0)
                                                       .getTransactionId
                                                       (= txid))
                                                  @tuples)]
                         (reset! tuples not-to-ack)
                         (doseq [t to-ack]
                           (.ack @collector t)))))

       ;; only check default streams
       (bind verify! (fn [expected]
