Re: [I] Streaming data ingestion support in Pinot for Redpanda. [pinot]

abhioncbr commented on issue #12155: URL: https://github.com/apache/pinot/issues/12155#issuecomment-1867991924 @Jackie-Jiang, please assign this to me. I will work on this. Thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

Re: [PR] fix: Pulsar OAuth2 Authentication Factory [pinot]

JeffBolle commented on PR #12195: URL: https://github.com/apache/pinot/pull/12195#issuecomment-1867740062 @KKcorps thank you for the speedy review. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go t

Re: [PR] fix: Pulsar OAuth2 Authentication Factory [pinot]

JeffBolle commented on code in PR #12195: URL: https://github.com/apache/pinot/pull/12195#discussion_r1435095045 ## pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarPartitionLevelConnectionHandler.java: ## @@ -73,10 +73,

Re: [PR] Add a 'lastUsed' option for resumeConsumption.consumeFrom [pinot]

codecov-commenter commented on PR #12200: URL: https://github.com/apache/pinot/pull/12200#issuecomment-1867650491 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/12200?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) R

[PR] Add a 'lastUsed' option for resumeConsumption.consumeFrom [pinot]

gortiz opened a new pull request, #12200: URL: https://github.com/apache/pinot/pull/12200 We recently find issues using the `resumeConsumption` endpoint and we think it would be better to improve the swagger usability. Specifically, in current version the swagger UI is: ![image](htt

Re: [PR] Bump org.apache.spark:spark-launcher_2.12 from 3.2.1 to 3.5.0 [pinot]

codecov-commenter commented on PR #12199: URL: https://github.com/apache/pinot/pull/12199#issuecomment-1867600402 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/12199?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) R

Re: [PR] Bump io.grpc:grpc-context from 1.59.0 to 1.60.1 [pinot]

codecov-commenter commented on PR #12198: URL: https://github.com/apache/pinot/pull/12198#issuecomment-1867599210 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/12198?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) R

Re: [PR] Bump io.airlift:aircompressor from 0.21 to 0.25 [pinot]

codecov-commenter commented on PR #12197: URL: https://github.com/apache/pinot/pull/12197#issuecomment-1867598224 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/12197?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=apache) R

(pinot) branch dependabot/maven/org.apache.spark-spark-launcher_2.12-3.5.0 created (now 1b6c890eb6)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/org.apache.spark-spark-launcher_2.12-3.5.0 in repository https://gitbox.apache.org/repos/asf/pinot.git at 1b6c890eb6 Bump org.apache.spark:spark-launcher_2.12 from 3.2

(pinot) branch dependabot/maven/io.grpc-grpc-context-1.60.1 created (now e9c127a403)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/io.grpc-grpc-context-1.60.1 in repository https://gitbox.apache.org/repos/asf/pinot.git at e9c127a403 Bump io.grpc:grpc-context from 1.59.0 to 1.60.1 No new revisions

[PR] Bump io.grpc:grpc-context from 1.59.0 to 1.60.1 [pinot]

dependabot[bot] opened a new pull request, #12198: URL: https://github.com/apache/pinot/pull/12198 Bumps [io.grpc:grpc-context](https://github.com/grpc/grpc-java) from 1.59.0 to 1.60.1. Release notes Sourced from https://github.com/grpc/grpc-java/releases";>io.grpc:grpc-context's

[PR] Bump org.apache.spark:spark-launcher_2.12 from 3.2.1 to 3.5.0 [pinot]

dependabot[bot] opened a new pull request, #12199: URL: https://github.com/apache/pinot/pull/12199 Bumps org.apache.spark:spark-launcher_2.12 from 3.2.1 to 3.5.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=

[PR] Bump io.airlift:aircompressor from 0.21 to 0.25 [pinot]

dependabot[bot] opened a new pull request, #12197: URL: https://github.com/apache/pinot/pull/12197 Bumps [io.airlift:aircompressor](https://github.com/airlift/aircompressor) from 0.21 to 0.25. Commits https://github.com/airlift/aircompressor/commit/dc4ece6ef0371807bd93de67e0fbe

(pinot) branch dependabot/maven/io.airlift-aircompressor-0.25 created (now 720579cc53)

This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/io.airlift-aircompressor-0.25 in repository https://gitbox.apache.org/repos/asf/pinot.git at 720579cc53 Bump io.airlift:aircompressor from 0.21 to 0.25 No new revisio

Re: [PR] Detect expired messages in Kafka. Log and set a guage. [pinot]

vrajat commented on code in PR #12157: URL: https://github.com/apache/pinot/pull/12157#discussion_r1434819785 ## pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java: ## @@ -1648,6 +1648,15 @@ private void makeStreamConsumer(String

Re: [PR] Detect expired messages in Kafka. Log and set a guage. [pinot]

vrajat commented on code in PR #12157: URL: https://github.com/apache/pinot/pull/12157#discussion_r1434819332 ## pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/RealtimeSegmentDataManager.java: ## @@ -1648,6 +1648,15 @@ private void makeStreamConsumer(String