Code

Add MemQ Flink consumer support#35

Code

Merged

jeffxiang merged 19 commits into3.1pinterest/psc:3.1from memq-flink-integration-3.1pinterest/psc:memq-flink-integration-3.1Copy head branch name to clipboardMay 16, 2024

+884-178

Commits

Commits on Mar 7, 2024

• Add MemQ Flink consumer support

  ArtemTetenkin

  committed
  2b27c68

  Copy full SHA for 2b27c68

Commits on Mar 11, 2024

• After CR1

  ArtemTetenkin

  committed
  170843f

  Copy full SHA for 170843f

Commits on Mar 19, 2024

• Remove unnecessary dependencies

  ArtemTetenkin

  committed
  e698bd1

  Copy full SHA for e698bd1

• Update version to 3.1.4-SNAPSHOT

  ArtemTetenkin

  committed
  4deb915

  Copy full SHA for 4deb915

Commits on Apr 18, 2024

• Add memqConsumer reset every hour

  ArtemTetenkin

  committed
  1e5ecb7

  Copy full SHA for 1e5ecb7

Commits on Apr 23, 2024

• Remove memqConsumer reset every hour

  ArtemTetenkin

  committed
  25a72e0

  Copy full SHA for 25a72e0

• Try pre-fetch into memory for PscMemqConsumer to catch SdkClientException

  jeffxiang

  committed
  5c00278

  Copy full SHA for 5c00278

• Remove unnecessary log

  ArtemTetenkin

  committed
  cf31c8d

  Copy full SHA for cf31c8d

• Revert memq consumer reset logic

  ArtemTetenkin

  committed
  e53ad97

  Copy full SHA for e53ad97

Commits on Apr 25, 2024

• Remove commented code

  ArtemTetenkin

  committed
  17eb01a

  Copy full SHA for 17eb01a

Commits on May 2, 2024

• Bump memq version to 0.2.21

  jeffxiang

  committed
  48210fc

  Copy full SHA for 48210fc

• Change version to 3.1.4-RC1

  ArtemTetenkin

  committed
  60f26a0

  Copy full SHA for 60f26a0

Commits on May 3, 2024

• Replace unnecessary key objects creation with map of keys, add PscEvent doc

  ArtemTetenkin

  committed
  adb0228

  Copy full SHA for adb0228

• Add javadoc

  ArtemTetenkin

  committed
  a0ef588

  Copy full SHA for a0ef588

Commits on May 8, 2024

• Try to fix ClassCastException for MemqTopicUri

  jeffxiang

  committed
  96fea98

  Copy full SHA for 96fea98

Commits on May 9, 2024

• Remove else if statement to ensure that validateTopicUriPartition is always called

  jeffxiang

  committed
  cd308e6

  Copy full SHA for cd308e6

Commits on May 14, 2024

• Update version to 3.2, other minor changes

  ArtemTetenkin

  committed
  051f4f6

  Copy full SHA for 051f4f6

Commits on May 15, 2024

• Update version to 3.2.0-RC1, other minor changes

  ArtemTetenkin

  committed
  75e3e3c

  Copy full SHA for 75e3e3c

Commits on May 16, 2024

• Update version to 3.2.0

  ArtemTetenkin

  committed
  8b817b0

  Copy full SHA for 8b817b0