Remove remove trpDynamicOptions after 1st read
@@ -96,7 +96,6 @@ public abstract class Sink implements SinkListener, Snapshotable {
@Override
public final void publish(Object payload) {
- try {
if (isConnected.get()) {
try {
DynamicOptions dynamicOptions = trpDynamicOptions.get();
@@ -115,10 +114,6 @@ public abstract class Sink implements SinkListener, Snapshotable {
connectWithRetry();
publish(payload);
}
- } finally {
- trpDynamicOptions.remove();
- }
-
}
/**
