File tree
2,265 files changed
+118766
-72045
lines changed- .github
- actions
- run-gradle
- setup-gradle
- scripts
- workflows
- bin
- checkstyle
- clients
- clients-integration-tests/src/test
- java/org/apache/kafka
- clients
- admin
- consumer
- producer
- server/quota
- resources
- src
- main
- java/org/apache/kafka
- clients
- admin
- internals
- consumer
- internals
- events
- producer
- internals
- common
- acl
- annotation
- config
- internals
- errors
- feature
- internals
- metrics
- internals
- protocol
- record
- replica
- requests
- resource
- security
- auth
- oauthbearer
- internals/secured
- token/delegation
- serialization
- utils
- server
- authorizer
- quota
- telemetry
- resources/common/message
- test/java/org/apache/kafka
- clients
- admin
- internals
- consumer
- internals
- events
- producer
- internals
- common
- acl
- config
- errors
- internals
- message
- metrics/internals
- network
- record
- requests
- security
- authenticator
- oauthbearer
- internals/secured
- utils
- test
- committer-tools
- config
- connect
- api/src
- main/java/org/apache/kafka/connect
- connector
- policy
- data
- rest
- sink
- source
- storage
- transforms
- predicates
- test/java/org/apache/kafka/connect
- data
- sink
- source
- file/src/main/java/org/apache/kafka/connect/file
- mirror-client/src/main/java/org/apache/kafka/connect/mirror
- mirror/src
- main/java/org/apache/kafka/connect/mirror
- test/java/org/apache/kafka/connect/mirror
- runtime/src
- main/java/org/apache/kafka/connect
- runtime
- distributed
- errors
- health
- isolation
- rest
- resources
- standalone
- storage
- tools
- util
- test
- java/org/apache/kafka/connect
- integration
- runtime
- distributed
- errors
- isolation
- rest
- util
- standalone
- util
- clusters
- resources/META-INF/services
- transforms/src/test/java/org/apache/kafka/connect/transforms/field
- coordinator-common/src
- main/java/org/apache/kafka/coordinator/common/runtime
- test/java/org/apache/kafka/coordinator/common/runtime
- core/src
- main
- java/kafka
- docker
- log/remote
- server
- builders
- handlers
- logger
- scala/kafka
- admin
- cluster
- common
- coordinator
- group
- transaction
- docker
- log
- metrics
- network
- raft
- server
- metadata
- tools
- utils
- json
- test
- java/kafka
- log/remote
- security
- minikdc
- server
- handlers
- integration
- logger
- test/api
- scala
- integration/kafka
- admin
- api
- coordinator/transaction
- server
- kafka
- raft
- server
- metadata
- utils
- unit/kafka
- admin
- cluster
- coordinator
- group
- transaction
- docker
- integration
- log
- remote
- metrics
- network
- raft
- security/authorizer
- server
- epoch
- metadata
- tools
- utils
- docker
- examples
- docker-compose-files
- cluster
- combined
- plaintext
- ssl
- isolated
- plaintext
- ssl
- single-node
- plaintext
- ssl
- fixtures/file-input
- jvm
- native
- native-image-configs
- test/fixtures
- file-input
- mode
- combined
- isolated
- docs
- documentation
- streams
- developer-guide
- generator/src
- main/java/org/apache/kafka/message
- checker
- test/java/org/apache/kafka/message/checker
- gradle
- group-coordinator
- group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor
- src
- main
- java/org/apache/kafka/coordinator/group
- assignor
- classic
- metrics
- modern
- consumer
- streams
- assignor
- topics
- resources/common/message
- test/java/org/apache/kafka/coordinator/group
- assignor
- classic
- metrics
- modern
- consumer
- streams
- assignor
- topics
- jmh-benchmarks/src/main/java/org/apache/kafka/jmh
- common
- coordinator
- fetcher
- log
- metadata
- partition
- record
- server
- metadata/src
- main
- java/org/apache/kafka
- controller
- errors
- metrics
- image
- loader
- metrics
- node
- publisher
- metrics
- writer
- metadata
- authorizer
- bootstrap
- placement
- properties
- publisher
- storage
- util
- resources/common/metadata
- test/java/org/apache/kafka
- controller
- metrics
- image
- loader
- metrics
- node
- printer
- publisher
- metrics
- writer
- metadata
- authorizer
- bootstrap
- placement
- properties
- storage
- util
- metalog
- raft/src
- main/java/org/apache/kafka
- raft
- internals
- snapshot
- test/java/org/apache/kafka
- raft
- internals
- snapshot
- release
- server-common/src
- main/java/org/apache/kafka
- admin
- config
- deferred
- queue
- server
- common
- config
- metrics
- network
- purgatory
- record
- storage/log
- util
- timeline
- test/java/org/apache/kafka
- common
- metadata
- queue
- server
- common
- immutable/pcollections
- metrics
- mutable
- network
- purgatory
- quota
- util
- timer
- timeline
- server/src
- main/java/org/apache/kafka
- network
- metrics
- security/authorizer
- server
- config
- metrics
- purgatory
- test/java/org/apache/kafka
- network
- security/authorizer
- server
- config
- metrics
- purgatory
- shell/src
- main/java/org/apache/kafka/shell
- test/java/org/apache/kafka/shell
- storage
- api/src/main/java/org/apache/kafka/server/log/remote/storage
- src
- main/java/org/apache/kafka
- server
- log/remote
- metadata/storage
- serialization
- quota
- storage
- purgatory
- storage
- internals
- epoch
- log
- log/metrics
- test
- java/org/apache/kafka
- server
- log
- remote
- metadata/storage
- quota
- storage
- purgatory
- storage/internals
- checkpoint
- log
- tiered/storage
- actions
- integration
- utils
- resources
- streams
- integration-tests/src/test/java/org/apache/kafka/streams/integration
- utils
- src
- main/java/org/apache/kafka/streams
- internals
- metrics
- kstream
- internals
- foreignkeyjoin
- graph
- processor
- api
- internals
- assignment
- state
- internals
- test/java/org/apache/kafka
- streams
- internals/metrics
- kstream
- internals
- foreignkeyjoin
- processor/internals
- assignment
- tasks
- state/internals
- tests
- test
- streams-scala/src/test/resources
- test-utils/src/main/java/org/apache/kafka/streams
- upgrade-system-tests-38/src/test/java/org/apache/kafka/streams/tests
- upgrade-system-tests-39/src/test/java/org/apache/kafka/streams/tests
- upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests
- test-common
- test-common-api/src/main/java/org/apache/kafka/common/test/api
- test-common-internal-api/src
- main/java/org/apache/kafka/common/test/api
- test
- java/org/apache/kafka/common/test/api
- resources
- test-common-runtime/src
- main
- java/org/apache/kafka/common/test
- junit
- resources
- META-INF/services
- test/java/org/apache/kafka/common/test
- junit
- test-common-util/src
- main
- java/org/apache/kafka/common/test
- api
- junit
- resources
- META-INF/services
- test/java/org/apache/kafka/common/test/junit
- tests
- docker
- kafkatest
- benchmarks/core
- sanity_checks
- services
- kafka
- templates
- tests
- client
- connect
- core
- streams
- tools
- utils
- tools/src
- main/java/org/apache/kafka/tools
- consumer
- group
- reassign
- streams
- test/java/org/apache/kafka/tools
- consumer
- group
- other
- reassign
- streams
- transaction-coordinator/src
- main/java/org/apache/kafka/coordinator/transaction
- test/java/org/apache/kafka/coordinator/transaction
- trogdor
- src
- main/java/org/apache/kafka/trogdor/workload
- test/java/org/apache/kafka/trogdor/workload
- vagrant
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,265 files changed
+118766
-72045
lines changedLines changed: 22 additions & 9 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
15 | 15 |
| |
16 | 16 |
| |
17 | 17 |
| |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
18 | 22 |
| |
19 | 23 |
| |
20 | 24 |
| |
| |||
25 | 29 |
| |
26 | 30 |
| |
27 | 31 |
| |
28 |
| - | |
29 |
| - | |
30 | 32 |
| |
31 |
| - | |
32 |
| - | |
33 |
| - | |
34 |
| - | |
35 |
| - | |
36 |
| - | |
37 |
| - | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + |
Lines changed: 40 additions & 5 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
22 | 22 |
| |
23 | 23 |
| |
24 | 24 |
| |
25 |
| - | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
26 | 29 |
| |
27 | 30 |
| |
28 | 31 |
| |
| |||
33 | 36 |
| |
34 | 37 |
| |
35 | 38 |
| |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
36 | 60 |
| |
37 | 61 |
| |
38 | 62 |
| |
39 | 63 |
| |
| 64 | + | |
40 | 65 |
| |
41 | 66 |
| |
42 | 67 |
| |
| |||
52 | 77 |
| |
53 | 78 |
| |
54 | 79 |
| |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
55 | 86 |
| |
56 | 87 |
| |
57 | 88 |
| |
58 | 89 |
| |
59 | 90 |
| |
60 |
| - | |
61 |
| - | |
62 |
| - | |
| 91 | + | |
| 92 | + | |
63 | 93 |
| |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
64 | 99 |
| |
65 | 100 |
| |
66 | 101 |
| |
| |||
72 | 107 |
| |
73 | 108 |
| |
74 | 109 |
| |
75 |
| - | |
| 110 | + |
Lines changed: 1 addition & 1 deletion
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
42 | 42 |
| |
43 | 43 |
| |
44 | 44 |
| |
45 |
| - | |
| 45 | + | |
46 | 46 |
| |
47 | 47 |
| |
48 | 48 |
| |
|
Lines changed: 11 additions & 0 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + |
0 commit comments