This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch kip1071
in repository https://gitbox.apache.org/repos/asf/kafka.git
omit ea5d5e67c2c MINOR: Added tests and side cleanup (#18069)
omit 1ae9778e077 Fixes from rebase/merge
omit f16c7214f55 Merge branch 'trunk_rebase_12_6' into kip1071
omit b2f7e25b34b KIP-1071: Fix StickyTaskAssignor (#18051)
omit b4852887186 MINOR: Fix epoch validation (#18065)
omit 343bb544289 Add KIP-1082 (#18044)
omit 5cc622a650f Use LeaveOnClose event with Streams membership manager
(#18054)
omit 0a5181d6b81 Implement support for streams groups in kafka-groups.sh
(#18043)
omit 9dd4f438b67 MINOR: add endpoint to sync RPCs with KIP (#18035)
omit f7642748f80 Add group.protocol config handling for streams (#18033)
omit 6f6cbef487e Follow-ups to the integration of Streams membership
manager (#18019)
omit 002045428ba MINOR: Updates from running spotless apply (#18007)
omit 84dd9aeab45 Topology epochs and topic validation (#17721)
omit 744679541e1 Remove unused import
omit c7deec0e70c Remove superfluous record version
omit b3eeed7a093 KIP1071 trunk rebase 11_25 add streams membership manager
stream thread integration (#17968)
omit 1e8284b71d2 Fixes from rebase
omit e19b7e08737 Correctness updates from rebase
omit 6b98ec67ee3 Resolve conflicts from 11/15 trunk rebase - Initialize
topologies as part of heartbeat (#17695)
omit dcb0c923ff7 Introduce the streams membership manager (#17564)
omit 4686728d883 Resolve conflicts from 11/25 trunk rebase - Internal topic
auto creation (#17433)
omit f5f901771ce Resolve conflicts from trunk rebase - Port tools for topic
configuration (#17371)
omit 16c51af4e20 Resolve conflicts from 11/25 trunk rebase - MINOR: Rebase
dev branch on current trunk
omit b18625b86ff Complete topic metadata for automatic topic creation
(#17391)
omit 0953df59d7b MINOR: Fix unit tests (#17374)
omit 8b6094c4e32 MINOR: Use subtopologyId and spelling consistently (#17370)
omit deb38899cc9 KAFKA-17125: finalize TaskId (#17300)
omit d1794f477ba Resolve conflict from 11/25 trunk rebase - Rebase on AK
trunk 2024-09-25
omit 51155f993e6 Add broker configs for streams group
omit 133a442e66b Resolve conflict from 11/25 trunk rebase - Streams
reconciliation logic
omit 7a9105b93fc Improve the Streams group initialization handler
omit 93b72dba05c Rename streamsHeartbeatX and streamsInitializeX to
streamsGroupX
omit eeea1ca9205 StickyTaskAssignor
omit a002fe9c241 Minor: Revert test changes
omit dc5b2ef7ecd Resolve conflict from 11/25 trunk rebase - Rebase on AK
trunk 2024-08-15
omit 6a4aa0cf1d4 Resolve conflicts from 11/25 trunk rebase - Implement
DescribeStreamsGroup RPC handling
omit 2dd10b7147e Resovle conflicts from 11/25 trunk rebase - Update RPCs
omit 6c36a43fe9d Resolve conflicts for 11/25 trunk rebase - Rebased on AK
trunk 2024-07-16
omit 7d73d52e8b6 Resolve conflicts from 11/25 rebase - Get
SmokeTestDriverIntegrationTest working
omit cc4985e5972 Reslove confict from 11/25 trunk rebase - Replay all
streams-related records
omit 049aece0aa3 Reslove conflicts from 11/25 rebase - Create
assignment-related classes for streams groups
omit d06afbd4a96 Define the assignor interface for streams and implement a
simple assignor
omit 9b448029274 Add streams group member
omit 4c64b358d62 Resolve conflict from 11/25 rebase Basic heartbeat RPC
handler
omit 41669d978ec Minor: Rename TaskId to TaskIds
omit 60f6773fa63 Add Assignment class in group coordinator for Streams
omit c1a597b211e Resolve merge conflict from 11/25 trunk rebase Implement
InitStreamsApp RPC in the group coordinator
omit 286314d72ae Define initial record types for the consumer offset topic
omit 8f22f7a6181 Minor: Test fixes
omit b2e6b80df6e Resolve conflict from 11/25 trunk rebase - Create and
inject StreamsHeartbeatRequestManager
omit a19bc7d97b7 Implement StreamsInitialize request manager
omit 9e3ba3e0f5a Resolve merge conflict from 11/25 rebase - Specify
AsyncKafkaConsumer interface with Streams for the Rebalance PoC
omit 7cd85abe2db Resolve merge conflict from 11/25 trunk rebase - Define
RPCs to perform client-side assignment
omit f8ecdc9a716 Reslove merge conflict from 11/25 trunk rebase -
StreamsInitialize RPC and some errors
omit 5eb61c087ca Very initial (compiling) streams RPCs.
new dc545b2b6ec MINOR: Added tests and side cleanup (#18069)
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ea5d5e67c2c)
\
N -- N -- N refs/heads/kip1071 (dc545b2b6ec)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
