Update BatchReceivePolicy.java
BatchReceivePolicy implements Serializable.
*/
package org.apache.pulsar.client.api;
+import java.io.Serializable;
import java.util.concurrent.TimeUnit;
/**
@@ -41,7 +42,9 @@ import java.util.concurrent.TimeUnit;
*
* @since 2.4.1
*/
-public class BatchReceivePolicy {
+public class BatchReceivePolicy implements Serializable {
+
+ private static final long serialVersionUID = 1L;
/**
* Default batch receive policy.
