Kafka-15126: Range queries to accept null lower and upper bounds#13987

Closed

Cerchie wants to merge 88 commits intoapache:trunkfrom

Cerchie:KAFKA-15126

Commits on Jul 10, 2023

Commits on Jul 13, 2023

enhance javadoc
Cerchie
committed

Commits on Jul 25, 2023

MINOR: Move TROGDOR.md to trogdor module (#13979)

authored and
Cerchie
committed
Doc fixes: Fix format and other small errors in config documentation (#13661)

cherylws
authored and
Cerchie
committed
KAFKA-14718: Wait for MirrorMaker to start before executing test (#13284)

divijvaidya
authored and
Cerchie
committed
KAFKA-14059 Replace PowerMock with Mockito in WorkerSourceTaskTest (#13383)

hgeraldino
authored and
Cerchie
committed
KAFKA-15145: Don't re-process records filtered out by SMTs on Kafka client retriable exceptions in AbstractWorkerSourceTask (#13955)

yashmayya
authored and
Cerchie
committed
KAFKA-15139: Avoid slow Set.removeAll(List) in MirrorCheckpointConnector (#13946)

hudeqi
authored and
Cerchie
committed
KAFKA-15159: upgrade minor dependencies (#13982)

authored and
Cerchie
committed
[KAFKA-15137] Do not log entire request payload in KRaftControllerChannelManager (#13988)

ahuang98
authored and
Cerchie
committed
KAFKA-15155: Follow PEP 8 best practice in Python to check if a container is empty (#13974)

cxorm
authored and
Cerchie
committed
KAFKA-12525: Ignoring stale status statuses when reading from Connect status topic (#13453)

vamossagar12
authored and
Cerchie
committed
KAFKA-14522 Rewrite/Move of RemoteIndexCache to storage module. (#13275)

satishd
authored and
Cerchie
committed
MINOR: Add Streams API broker compatibility table (#13937)

JimGalasyn
authored and
Cerchie
committed
MINOR: Add 3.5.0 and 3.4.1 to system tests (#13849)

mimaison
authored and
Cerchie
committed
KAFKA-15093: Add 3.4.0 and 3.5.0 to core upgrade and compatibility system tests (#13859)

mimaison
authored and
Cerchie
committed
MINOR: Capture build scans on ge.apache.org to benefit from deep build insights (#13676)

clayburn
authored and
Cerchie
committed
KAFKA-14462; [22/N] Implement session and revocation timeouts (#13963)

dajac
authored and
Cerchie
committed
MINOR: Fix Jmxtool to honour wait option when MBean is not yet avaibale in MBean server (#13995)

omkreddy
authored and
Cerchie
committed
KAFKA-15148: Mark tests correctly as integration tests where they running as unit tests (#13973)

eziosudo
authored and
Cerchie
committed
KAFKA-14938: Fixing flaky test testConnectorBoundary (#13646)

sambhav-jain-16
authored and
Cerchie
committed
MINOR: Avoid slow Set.removeAll(List) in MirrorSourceConnector (#13992)

hudeqi
authored and
Cerchie
committed
Kafka Streams Threading: Exception handling (#13957)

lucasbru
authored and
Cerchie
committed
MINOR: Standardize controller log4j output for replaying records (#13703)

cmccabe
authored and
Cerchie
committed
KAFKA-12261: Mention about potential delivery loss on increasing partition when auto.offset.reset = latest (#10167)

ocadaruma
authored and
Cerchie
committed
Fix compile test error (#14013)

mumrah
authored and
Cerchie
committed
MINOR: Remove thread leak from ConsumerBounceTest (#13956)

divijvaidya
authored and
Cerchie
committed
KAFKA-15180: Generalize integration tests to change use of KafkaConsumer to Consumer (#13997)

kirktrue
authored and
Cerchie
committed
KAFKA-14462; [23/23] Wire GroupCoordinatorService in BrokerServer (#13991)

dajac
authored and
Cerchie
committed
KAFKA-15182: Normalize source connector offsets before invoking SourceConnector::alterOffsets (#14003)

yashmayya
authored and
Cerchie
committed
MINOR Improve logging during the ZK to KRaft migration (#14008)

mumrah
authored and
Cerchie
committed
KAFKA-14884: Include check transaction is still ongoing right before append (take 2) (#13787)

jolshan
authored and
Cerchie
committed
KAFKA-15123: Add tests for ChunkedBytesStream (#13941)

riedelmax
authored and
Cerchie
committed
fix typo in streams/dsl-api.html (#14023)

iblislin
authored and
Cerchie
committed
MINOR: Add ZK dual-write lag metric (#14009)

hni61223
authored and
Cerchie
committed
KAFKA-9564: Local Tiered Storage implementation for Remote Storage Manager (#13837)

kamalcph
authored and
Cerchie
committed
MINOR: remove unused variable in examples (#14021)

bmscomp
authored and
Cerchie
committed
KAFKA-14647: Move TopicFilter to server-common/utils (#13158)

vamossagar12
authored and
Cerchie
committed
KAFKA-14737: Move kafka.utils.json to server-common (#13585)

OmniaGM
authored and
Cerchie
committed
MINOR: Update .asf.yaml file with refreshed github_whitelist, and collaborators

mimaison
authored and
Cerchie
committed
Revert "MINOR: Update .asf.yaml file with refreshed github_whitelist, and collaborators" (#14037)

mimaison
authored and
Cerchie
committed
KAFKA-15121: Implement the alterOffsets method in the FileStreamSourceConnector and the FileStreamSinkConnector (#13945)

yashmayya
authored and
Cerchie
committed
KAFKA-14953: Add tiered storage related metrics (#13944)

abhijeetk88
authored and
Cerchie
committed
KAFKA-14669: Use the generated docs for MirrorMaker configs in the doc (#13658)

tinaselenge
authored and
Cerchie
committed
KAFKA-15091: Fix misleading Javadoc for SourceTask::commit (#13948)

yashmayya
authored and
Cerchie
committed
MINOR: Update docs to include ZK deprecation notice and information (#14031)

forlack
authored and
Cerchie
committed
KAFKA-14500; [5/N] Implement JoinGroup protocol in new GroupCoordinator (#13870)

jeffkbkim
authored and
Cerchie
committed
KAFKA-15199: Remove Leading and Trailing Spaces in release.py (#14035)

tanay27
authored and
Cerchie
committed
MINOR: Upgrade Gradle wrapper version to 8.2.1 (#14032)

bmscomp
authored and
Cerchie
committed
KAFKA-15211: Mock InvalidParameterException in DistributedConfigTest (#14039)

gharris1727
authored and
Cerchie
committed
MINOR: Fix Connect compatibility javadocs to use NoSuchMethodError instead of NoSuchMethodException (#14036)

yashmayya
authored and
Cerchie
committed
KAFKA-15141: Initialize logger statically on hot codepaths (#13949)

gaurav-narula
authored and
Cerchie
committed
KAFKA-15162: Reflectively find plugins in parent ClassLoaders that aren't on the classpath (#13977)

gharris1727
authored and
Cerchie
committed
KAFKA-10579: Upgrade reflections from 0.9.12 to 0.10.2 (#14029)

gharris1727
authored and
Cerchie
committed
KAFKA-15150: Add ServiceLoaderScanner implementation (#13971)

gharris1727
authored and
Cerchie
committed
MINOR: Delete unneeded classgraph-MIT license (#14040)

tanay27
authored and
Cerchie
committed
KAFKA-14734: Use CommandDefaultOptions in StreamsResetter (#13983)

fvaleri
authored and
Cerchie
committed
KAFKA-14936: Check the versioned table's history retention and compare to grace period (4/N) (#13942)

wcarlson5
authored and
Cerchie
committed
KAFKA-15216: InternalSinkRecord::newRecord should not ignore new headers (#14044)

yashmayya
authored and
Cerchie
committed
KAFKA-14469: Add MirrorMaker configs to table of contents in docs page (#14041)

C0urante
authored and
Cerchie
committed
KAFKA-14133: Migrate various mocks in TaskManagerTest to Mockito (#13874)

clolov
authored and
Cerchie
committed
KAFKA-14760: Move ThroughputThrottler from tools to clients, remove tools dependency from connect-runtime (#13313)

gharris1727
authored and
Cerchie
committed
KAFKA-15022: [2/N] introduce graph to compute min cost (#13996)

lihaosky
authored and
Cerchie
committed
KAFKA-15176: add tests for tiered storage metrics (#13999)

showuon
authored and
Cerchie
committed
MINOR Fix the build failure (#14065)

satishd
authored and
Cerchie
committed
KAFKA-15222: upgrade zinc scala plugin to 1.9.2 (#14060)

bmscomp
authored and
Cerchie
committed
MINOR: add JDK 20 build support to README (#14061)

bmscomp
authored and
Cerchie
committed
KAFKA-14591: Move DeleteRecordsCommand to tools (#13278)

nizhikov
authored and
Cerchie
committed
KAFKA-13431 (KIP-793): Expose the original pre-transform topic partition and offset in sink records (#14024)

yashmayya
authored and
Cerchie
committed
KAFKA-14499: [1/N] Introduce OffsetCommit API version 9 and add new StaleMemberEpochException error (#14046)

dajac
authored and
Cerchie
committed
KAFKA-14499: [2/N] Add OffsetCommit record & related (#14047)

dajac
authored and
Cerchie
committed
KAFKA-15232: Move ToolsUtils to tools (#14066)

fvaleri
authored and
Cerchie
committed
KAFKA-14950: implement assign() and assignment() (#13797)

authored and
Cerchie
committed
MINOR: Minor logging and doc related improvements in topic-based RLMM consumer-manager/task (#14045)

jeqo
authored and
Cerchie
committed
KAFKA-15194: Prepend offset in the filenames used by LocalTieredStorage (#14057)

Owen-CH-Leung
authored and
Cerchie
committed
KAFKA-14712: Produce correct error msg with correct metadataversion (#13773)

Owen-CH-Leung
authored and
Cerchie
committed
KAFKA-15168: Handle overlapping remote log segments in RemoteLogMetadata cache (#14004)

kamalcph
authored and
Cerchie
committed
KAFKA-14920: Address timeouts and out of order sequences (#14033)

jolshan
authored and
Cerchie
committed
KAFKA-14990: Dynamic producer ID expiration should be applied on a broker restart (#13707)

splett2
authored and
Cerchie
committed
KAFKA-15183: Add more controller, loader, snapshot emitter metrics (#14010)

cmccabe
authored and
Cerchie
committed
MINOR: Downgrade log level for conflicting Connect plugin aliases (#14081)

C0urante
authored and
Cerchie
committed
KAFKA-15238: Move DLQ reporter setup from the DistributedHerder's tick thread to the sink task thread (#14079)

yashmayya
authored and
Cerchie
committed
MINOR: Fix typo in ProduceRequest.json (#14070)

tisonkun
authored and
Cerchie
committed
rebase jul 25
Cerchie
committed
Merge branch 'trunk' into KAFKA-15126
Cerchie
authored

Commits on Jul 31, 2023

Merge branch 'apache:trunk' into KAFKA-15126
Cerchie
authored