                         (.createTopology builder)))
        (submit-local-topology (:nimbus cluster)
                               "transactional-test"
-                              {TOPOLOGY-MAX-SPOUT-PENDING 2
-                               TOPOLOGY-DEBUG true}
+                              {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)))))
+       (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]

       ;;       (println (read-tuples results "count"))
       (-> topo-info :capturer .getAndClearResults)
       ))))

       (tracked-wait topo-info 2)
       (println "Controlled: " @tuples)
       (println "Captured:" (-> topo-info :capturer .getResults))
       (verify! {"sum" [[1 "dog" 3]
                        [1 "cat" 5]
                        [1 "mango" 6]
                        [1 "happy" 11]
                        [2 "apple" 1]
                        [2 "dog" 3]
                        [2 "zebra" 1]]
                 "count" []
                 "count2" []})
       (ack-tx! 1)
       (tracked-wait topo-info 1)
       (verify! {"sum" []
                 "count" [[1 "dog" 1]
                          [1 "cat" 2]
                          [1 "mango" 2]
                          [1 "happy" 1]]
                 "count2" [[1 "dog" 2]
                           [1 "cat" 2]
                           [1 "mango" 2]
                           [1 "happy" 2]]})
       (ack-tx! 1)
       
       ;; ack the commit
       ;; check that third batch is emitted
       ;; ack the third batch
