Tags: pinterest/psc
Tags
Add MemQ Flink consumer support (#35) * Add MemQ Flink consumer support * After CR1 * Remove unnecessary dependencies * Update version to 3.1.4-SNAPSHOT * Add memqConsumer reset every hour * Remove memqConsumer reset every hour * Try pre-fetch into memory for PscMemqConsumer to catch SdkClientException * Remove unnecessary log * Revert memq consumer reset logic * Remove commented code * Bump memq version to 0.2.21 * Change version to 3.1.4-RC1 * Replace unnecessary key objects creation with map of keys, add PscEvent doc * Add javadoc * Try to fix ClassCastException for MemqTopicUri * Remove else if statement to ensure that validateTopicUriPartition is always called * Update version to 3.2, other minor changes * Update version to 3.2.0-RC1, other minor changes * Update version to 3.2.0 --------- Co-authored-by: artem <[email protected]> Co-authored-by: ArtemTetenkin <[email protected]>