Resolve merge conflict.

MaterializeInc · Apr 17, 2020 · e349aeb · e349aeb
1 parent d291a33
commit e349aeb
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/dataflow/source/kafka.rs b/src/dataflow/source/kafka.rs
@@ -264,7 +264,7 @@ where
                                 bytes_read += out.len() as i64;
                                 output
                                     .session(&cap)
-                                    .give((key, (out, Some(message.offset()))));
+                                    .give((key, (out, Some(message.offset))));
 
                                 downgrade_capability(
                                     &id,