Repository navigation

feature #193: Pause/Resume ParallelConsumer - #198

Merged

Antony Stubbs (astubbs) merged 59 commits into

confluentinc:masterfrom

nioertel:features/pause-resume

May 16, 2022

Merged

feature #193: Pause/Resume ParallelConsumer#198
Antony Stubbs (astubbs) merged 59 commits into
confluentinc:masterfrom
nioertel:features/pause-resume

Commits on Apr 6, 2022
- START: the basics of a single queue
  Antony Stubbs (astubbs)
  committed
  21f08f6
- step: remove work mailbox manager
  Antony Stubbs (astubbs)
  committed
  3f1f3ff
- step: BROKEN: assign epoch to record immediately
  Antony Stubbs (astubbs)
  committed
  92b50cb
- step - trying to test perf
  Antony Stubbs (astubbs)
  committed
  1653bc2
- update
  Antony Stubbs (astubbs)
  committed
  103c677
- logs
  Antony Stubbs (astubbs)
  committed
  eed2190
- fix: Debug output for sorted encoding pairs
  Antony Stubbs (astubbs)
  committed
  02ee3cd
- save
  Antony Stubbs (astubbs)
  committed
  83fda73
- rebase update
  Antony Stubbs (astubbs)
  committed
  2a37d46
- step
  Antony Stubbs (astubbs)
  committed
  b17c838
- save
  Antony Stubbs (astubbs)
  committed
  e1141e4
- save
  Antony Stubbs (astubbs)
  committed
  5a3bb55
- save: unit test version of offset encoding backpressure test
  Antony Stubbs (astubbs)
  committed
  6a1464c
- save
  Antony Stubbs (astubbs)
  committed
  0604934
- omg - hashsets vs queues, wow
  Antony Stubbs (astubbs)
  committed
  4eeb008
- review
  Antony Stubbs (astubbs)
  committed
  bcfc9c1
- review
  Antony Stubbs (astubbs)
  committed
  6054ac5
- review
  Antony Stubbs (astubbs)
  committed
  c968629
- review
  Antony Stubbs (astubbs)
  committed
  0f993dd
Commits on Apr 21, 2022
- Merge remote-tracking branch 'confluent/master' into features/single-queue
  Antony Stubbs (astubbs)
  committed
  416fd2f
- step
  Antony Stubbs (astubbs)
  committed
  189dc59
- step
  Antony Stubbs (astubbs)
  committed
  908d8ed
- fix test
  Antony Stubbs (astubbs)
  committed
  7547ec6
- step - test fix?
  Antony Stubbs (astubbs)
  committed
  939a15e
- step - test fix?
  Antony Stubbs (astubbs)
  committed
  3fa6ae3
- step - test fix? - make sure unit test also cleans up
  Antony Stubbs (astubbs)
  committed
  c44f50a
- step - test fix? - make sure unit test also cleans up
  Antony Stubbs (astubbs)
  committed
  eff0b13
- step: reduce consumer max poll
  Antony Stubbs (astubbs)
  committed
  74e0efb
- step: loosen duplicate check a bit for jenkins
  Antony Stubbs (astubbs)
  committed
  ae1ce22
- step: fix generics
  Antony Stubbs (astubbs)
  committed
  62ffa63
- step: Experiment: synchronisation no longer needed due to stronger epoch tracking?
  Antony Stubbs (astubbs)
  committed
  bf4452e
- turn max poll back to default (500)
  Antony Stubbs (astubbs)
  committed
  94ebc5c
- Draft for pause/resume functionality (confluentinc/parallel-consumer#193)
  
  Niels Oertel (nioertel)
  authored and
  Antony Stubbs (astubbs)
  committed
  854c0fa
- Improve logging + add unit tests (confluentinc/parallel-consumer#193).
  
  Niels Oertel (nioertel)
  authored and
  Antony Stubbs (astubbs)
  committed
  1401a28
- Fix copyrights.
  
  Niels Oertel (nioertel)
  authored and
  Antony Stubbs (astubbs)
  committed
  cada440
- Don't pause the BrokerPollSystem when pausing the consumer. Improve javadoc + test coverage (confluentinc#193).
  
  Niels Oertel (nioertel)
  authored and
  Antony Stubbs (astubbs)
  committed
  2761631
- Polish: Make MDC key for work container descriptor a constant.
  
  Niels Oertel (nioertel)
  authored and
  Antony Stubbs (astubbs)
  committed
  dcc01bc
- step: tweeks
  Antony Stubbs (astubbs)
  committed
  0d9a4fc
- step: simplify
  Antony Stubbs (astubbs)
  committed
  77520e4
- step: review
  Antony Stubbs (astubbs)
  committed
  439ad74
- step: turn back up default timeout to 30 - 10 is too low for some things
  Antony Stubbs (astubbs)
  committed
  753ea81
- update
  Antony Stubbs (astubbs)
  committed
  d7f9978
- review
  Antony Stubbs (astubbs)
  committed
  74eac43
- rebase compile update
  Antony Stubbs (astubbs)
  committed
  76c6fef
Commits on Apr 22, 2022
- review
  Antony Stubbs (astubbs)
  committed
  b85fd2d
- review
  Antony Stubbs (astubbs)
  committed
  c6056fe
- review
  Antony Stubbs (astubbs)
  committed
  333ccac
- review
  Antony Stubbs (astubbs)
  committed
  d751aa4
- fix
  Antony Stubbs (astubbs)
  committed
  aa5c0e1
- START: Rename PartitionMonitor to PartitionStateManager
  Antony Stubbs (astubbs)
  committed
  3b51ffe
- Merge branch 'features/single-queue' into features/pause-resume
  Antony Stubbs (astubbs)
  committed
  e336064
- START: Rename PartitionMonitor to PartitionStateManager
  Antony Stubbs (astubbs)
  committed
  cc5debf
- Merge branch 'pm-rename' into features/pause-resume
  Antony Stubbs (astubbs)
  committed
  cd4b59a
- Merge remote-tracking branch 'confluent/master' into features/pause-resume
  Antony Stubbs (astubbs)
  committed
  4f137fa
Commits on May 16, 2022
- Merge remote-tracking branch 'confluent/master' into features/pause-resume
  Antony Stubbs (astubbs)
  committed
  64a9f1e
- docs
  Antony Stubbs (astubbs)
  committed
  b6ad2ec
- review
  Antony Stubbs (astubbs)
  committed
  9164c44
- review
  Antony Stubbs (astubbs)
  committed
  968704b
- fix test - processing order will affect the actual offsets that are committed
  Antony Stubbs (astubbs)
  committed
  2a9e5c8

Commits

Commits on Apr 6, 2022

Commits on Apr 21, 2022

Commits on Apr 22, 2022

Commits on May 16, 2022