Path Lines of Code CONTRIBUTING.md 8 README.md 197 checkstyle/checkstyle.xml 115 checkstyle/import-control-clients-integration-tests.xml 15 checkstyle/import-control-coordinator-common.xml 47 checkstyle/import-control-core.xml 115 checkstyle/import-control-examples.xml 19 checkstyle/import-control-group-coordinator.xml 65 checkstyle/import-control-jmh-benchmarks.xml 50 checkstyle/import-control-metadata.xml 182 checkstyle/import-control-server-common.xml 96 checkstyle/import-control-server.xml 74 checkstyle/import-control-share-coordinator.xml 54 checkstyle/import-control-storage.xml 117 checkstyle/import-control-test-common-internal-api.xml 19 checkstyle/import-control-test-common-runtime.xml 13 checkstyle/import-control-test-common-util.xml 8 checkstyle/import-control-transaction-coordinator.xml 27 checkstyle/import-control.xml 580 checkstyle/suppressions.xml 265 clients/src/main/resources/common/message/AddOffsetsToTxnRequest.json 39 clients/src/main/resources/common/message/AddOffsetsToTxnResponse.json 34 clients/src/main/resources/common/message/AddPartitionsToTxnRequest.json 64 clients/src/main/resources/common/message/AddPartitionsToTxnResponse.json 59 clients/src/main/resources/common/message/AddRaftVoterRequest.json 41 clients/src/main/resources/common/message/AddRaftVoterResponse.json 29 clients/src/main/resources/common/message/AllocateProducerIdsRequest.json 28 clients/src/main/resources/common/message/AllocateProducerIdsResponse.json 31 clients/src/main/resources/common/message/AlterClientQuotasRequest.json 46 clients/src/main/resources/common/message/AlterClientQuotasResponse.json 40 clients/src/main/resources/common/message/AlterConfigsRequest.json 42 clients/src/main/resources/common/message/AlterConfigsResponse.json 38 clients/src/main/resources/common/message/AlterPartitionReassignmentsRequest.json 41 clients/src/main/resources/common/message/AlterPartitionReassignmentsResponse.json 46 clients/src/main/resources/common/message/AlterPartitionRequest.json 58 clients/src/main/resources/common/message/AlterPartitionResponse.json 55 clients/src/main/resources/common/message/AlterReplicaLogDirsRequest.json 40 clients/src/main/resources/common/message/AlterReplicaLogDirsResponse.json 40 clients/src/main/resources/common/message/AlterShareGroupOffsetsRequest.json 38 clients/src/main/resources/common/message/AlterShareGroupOffsetsResponse.json 37 clients/src/main/resources/common/message/AlterUserScramCredentialsRequest.json 44 clients/src/main/resources/common/message/AlterUserScramCredentialsResponse.json 34 clients/src/main/resources/common/message/ApiVersionsRequest.json 33 clients/src/main/resources/common/message/ApiVersionsResponse.json 78 clients/src/main/resources/common/message/AssignReplicasToDirsRequest.json 42 clients/src/main/resources/common/message/AssignReplicasToDirsResponse.json 43 clients/src/main/resources/common/message/BeginQuorumEpochRequest.json 55 clients/src/main/resources/common/message/BeginQuorumEpochResponse.json 52 clients/src/main/resources/common/message/BrokerHeartbeatRequest.json 36 clients/src/main/resources/common/message/BrokerHeartbeatResponse.json 33 clients/src/main/resources/common/message/BrokerRegistrationRequest.json 64 clients/src/main/resources/common/message/BrokerRegistrationResponse.json 32 clients/src/main/resources/common/message/ConsumerGroupDescribeRequest.json 30 clients/src/main/resources/common/message/ConsumerGroupDescribeResponse.json 96 clients/src/main/resources/common/message/ConsumerGroupHeartbeatRequest.json 50 clients/src/main/resources/common/message/ConsumerGroupHeartbeatResponse.json 61 clients/src/main/resources/common/message/ConsumerProtocolAssignment.json 41 clients/src/main/resources/common/message/ConsumerProtocolSubscription.json 47 clients/src/main/resources/common/message/ControlledShutdownRequest.json 21 clients/src/main/resources/common/message/ControlledShutdownResponse.json 21 clients/src/main/resources/common/message/ControllerRegistrationRequest.json 50 clients/src/main/resources/common/message/ControllerRegistrationResponse.json 29 clients/src/main/resources/common/message/CreateAclsRequest.json 45 clients/src/main/resources/common/message/CreateAclsResponse.json 36 clients/src/main/resources/common/message/CreateDelegationTokenRequest.json 44 clients/src/main/resources/common/message/CreateDelegationTokenResponse.json 52 clients/src/main/resources/common/message/CreatePartitionsRequest.json 46 clients/src/main/resources/common/message/CreatePartitionsResponse.json 40 clients/src/main/resources/common/message/CreateTopicsRequest.json 64 clients/src/main/resources/common/message/CreateTopicsResponse.json 71 clients/src/main/resources/common/message/DefaultPrincipalData.json 30 clients/src/main/resources/common/message/DeleteAclsRequest.json 45 clients/src/main/resources/common/message/DeleteAclsResponse.json 58 clients/src/main/resources/common/message/DeleteGroupsRequest.json 29 clients/src/main/resources/common/message/DeleteGroupsResponse.json 35 clients/src/main/resources/common/message/DeleteRecordsRequest.json 40 clients/src/main/resources/common/message/DeleteRecordsResponse.json 41 clients/src/main/resources/common/message/DeleteShareGroupOffsetsRequest.json 31 clients/src/main/resources/common/message/DeleteShareGroupOffsetsResponse.json 52 clients/src/main/resources/common/message/DeleteShareGroupStateRequest.json 36 clients/src/main/resources/common/message/DeleteShareGroupStateResponse.json 44 clients/src/main/resources/common/message/DeleteTopicsRequest.json 42 clients/src/main/resources/common/message/DeleteTopicsResponse.json 51 clients/src/main/resources/common/message/DescribeAclsRequest.json 42 clients/src/main/resources/common/message/DescribeAclsResponse.json 54 clients/src/main/resources/common/message/DescribeClientQuotasRequest.json 36 clients/src/main/resources/common/message/DescribeClientQuotasResponse.json 47 clients/src/main/resources/common/message/DescribeClusterRequest.json 34 clients/src/main/resources/common/message/DescribeClusterResponse.json 55 clients/src/main/resources/common/message/DescribeConfigsRequest.json 41 clients/src/main/resources/common/message/DescribeConfigsResponse.json 66 clients/src/main/resources/common/message/DescribeDelegationTokenRequest.json 35 clients/src/main/resources/common/message/DescribeDelegationTokenResponse.json 59 clients/src/main/resources/common/message/DescribeGroupsRequest.json 37 clients/src/main/resources/common/message/DescribeGroupsResponse.json 73 clients/src/main/resources/common/message/DescribeLogDirsRequest.json 36 clients/src/main/resources/common/message/DescribeLogDirsResponse.json 60 clients/src/main/resources/common/message/DescribeProducersRequest.json 31 clients/src/main/resources/common/message/DescribeProducersResponse.json 54 clients/src/main/resources/common/message/DescribeQuorumRequest.json 38 clients/src/main/resources/common/message/DescribeQuorumResponse.json 81 clients/src/main/resources/common/message/DescribeShareGroupOffsetsRequest.json 36 clients/src/main/resources/common/message/DescribeShareGroupOffsetsResponse.json 62 clients/src/main/resources/common/message/DescribeTopicPartitionsRequest.json 39 clients/src/main/resources/common/message/DescribeTopicPartitionsResponse.json 65 clients/src/main/resources/common/message/DescribeTransactionsRequest.json 26 clients/src/main/resources/common/message/DescribeTransactionsResponse.json 51 clients/src/main/resources/common/message/DescribeUserScramCredentialsRequest.json 29 clients/src/main/resources/common/message/DescribeUserScramCredentialsResponse.json 44 clients/src/main/resources/common/message/ElectLeadersRequest.json 40 clients/src/main/resources/common/message/ElectLeadersResponse.json 44 clients/src/main/resources/common/message/EndQuorumEpochRequest.json 62 clients/src/main/resources/common/message/EndQuorumEpochResponse.json 52 clients/src/main/resources/common/message/EndTxnMarker.json 25 clients/src/main/resources/common/message/EndTxnRequest.json 42 clients/src/main/resources/common/message/EndTxnResponse.json 40 clients/src/main/resources/common/message/EnvelopeRequest.json 31 clients/src/main/resources/common/message/EnvelopeResponse.json 29 clients/src/main/resources/common/message/ExpireDelegationTokenRequest.json 31 clients/src/main/resources/common/message/ExpireDelegationTokenResponse.json 32 clients/src/main/resources/common/message/FetchRequest.json 119 clients/src/main/resources/common/message/FetchResponse.json 121 clients/src/main/resources/common/message/FetchSnapshotRequest.json 57 clients/src/main/resources/common/message/FetchSnapshotResponse.json 73 clients/src/main/resources/common/message/FindCoordinatorRequest.json 42 clients/src/main/resources/common/message/FindCoordinatorResponse.json 57 clients/src/main/resources/common/message/GetTelemetrySubscriptionsRequest.json 28 clients/src/main/resources/common/message/GetTelemetrySubscriptionsResponse.json 59 clients/src/main/resources/common/message/HeartbeatRequest.json 38 clients/src/main/resources/common/message/HeartbeatResponse.json 34 clients/src/main/resources/common/message/IncrementalAlterConfigsRequest.json 43 clients/src/main/resources/common/message/IncrementalAlterConfigsResponse.json 37 clients/src/main/resources/common/message/InitProducerIdRequest.json 48 clients/src/main/resources/common/message/InitProducerIdResponse.json 46 clients/src/main/resources/common/message/InitializeShareGroupStateRequest.json 40 clients/src/main/resources/common/message/InitializeShareGroupStateResponse.json 42 clients/src/main/resources/common/message/JoinGroupRequest.json 64 clients/src/main/resources/common/message/JoinGroupResponse.json 70 clients/src/main/resources/common/message/KRaftVersionRecord.json 26 clients/src/main/resources/common/message/LeaderAndIsrRequest.json 21 clients/src/main/resources/common/message/LeaderAndIsrResponse.json 21 clients/src/main/resources/common/message/LeaderChangeMessage.json 39 clients/src/main/resources/common/message/LeaveGroupRequest.json 46 clients/src/main/resources/common/message/LeaveGroupResponse.json 45 clients/src/main/resources/common/message/ListClientMetricsResourcesRequest.json 24 clients/src/main/resources/common/message/ListClientMetricsResourcesResponse.json 32 clients/src/main/resources/common/message/ListGroupsRequest.json 35 clients/src/main/resources/common/message/ListGroupsResponse.json 48 clients/src/main/resources/common/message/ListOffsetsRequest.json 67 clients/src/main/resources/common/message/ListOffsetsResponse.json 66 clients/src/main/resources/common/message/ListPartitionReassignmentsRequest.json 33 clients/src/main/resources/common/message/ListPartitionReassignmentsResponse.json 45 clients/src/main/resources/common/message/ListTransactionsRequest.json 38 clients/src/main/resources/common/message/ListTransactionsResponse.json 40 clients/src/main/resources/common/message/MetadataRequest.json 55 clients/src/main/resources/common/message/MetadataResponse.json 99 clients/src/main/resources/common/message/OffsetCommitRequest.json 74 clients/src/main/resources/common/message/OffsetCommitResponse.json 70 clients/src/main/resources/common/message/OffsetDeleteRequest.json 38 clients/src/main/resources/common/message/OffsetDeleteResponse.json 41 clients/src/main/resources/common/message/OffsetFetchRequest.json 71 clients/src/main/resources/common/message/OffsetFetchResponse.json 100 clients/src/main/resources/common/message/OffsetForLeaderEpochRequest.json 51 clients/src/main/resources/common/message/OffsetForLeaderEpochResponse.json 50 clients/src/main/resources/common/message/ProduceRequest.json 72 clients/src/main/resources/common/message/ProduceResponse.json 95 clients/src/main/resources/common/message/PushTelemetryRequest.json 44 clients/src/main/resources/common/message/PushTelemetryResponse.json 31 clients/src/main/resources/common/message/README.md 208 clients/src/main/resources/common/message/ReadShareGroupStateRequest.json 38 clients/src/main/resources/common/message/ReadShareGroupStateResponse.json 59 clients/src/main/resources/common/message/ReadShareGroupStateSummaryRequest.json 38 clients/src/main/resources/common/message/ReadShareGroupStateSummaryResponse.json 50 clients/src/main/resources/common/message/RemoveRaftVoterRequest.json 30 clients/src/main/resources/common/message/RemoveRaftVoterResponse.json 29 clients/src/main/resources/common/message/RenewDelegationTokenRequest.json 31 clients/src/main/resources/common/message/RenewDelegationTokenResponse.json 32 clients/src/main/resources/common/message/RequestHeader.json 42 clients/src/main/resources/common/message/ResponseHeader.json 25 clients/src/main/resources/common/message/SaslAuthenticateRequest.json 28 clients/src/main/resources/common/message/SaslAuthenticateResponse.json 33 clients/src/main/resources/common/message/SaslHandshakeRequest.json 30 clients/src/main/resources/common/message/SaslHandshakeResponse.json 31 clients/src/main/resources/common/message/ShareAcknowledgeRequest.json 51 clients/src/main/resources/common/message/ShareAcknowledgeResponse.json 76 clients/src/main/resources/common/message/ShareFetchRequest.json 69 clients/src/main/resources/common/message/ShareFetchResponse.json 89 clients/src/main/resources/common/message/ShareGroupDescribeRequest.json 31 clients/src/main/resources/common/message/ShareGroupDescribeResponse.json 90 clients/src/main/resources/common/message/ShareGroupHeartbeatRequest.json 37 clients/src/main/resources/common/message/ShareGroupHeartbeatResponse.json 60 clients/src/main/resources/common/message/SnapshotFooterRecord.json 24 clients/src/main/resources/common/message/SnapshotHeaderRecord.json 26 clients/src/main/resources/common/message/StopReplicaRequest.json 21 clients/src/main/resources/common/message/StopReplicaResponse.json 21 clients/src/main/resources/common/message/StreamsGroupDescribeRequest.json 32 clients/src/main/resources/common/message/StreamsGroupDescribeResponse.json 162 clients/src/main/resources/common/message/StreamsGroupHeartbeatRequest.json 130 clients/src/main/resources/common/message/StreamsGroupHeartbeatResponse.json 115 clients/src/main/resources/common/message/SyncGroupRequest.json 55 clients/src/main/resources/common/message/SyncGroupResponse.json 45 clients/src/main/resources/common/message/TxnOffsetCommitRequest.json 67 clients/src/main/resources/common/message/TxnOffsetCommitResponse.json 46 clients/src/main/resources/common/message/UnregisterBrokerRequest.json 26 clients/src/main/resources/common/message/UnregisterBrokerResponse.json 29 clients/src/main/resources/common/message/UpdateFeaturesRequest.json 42 clients/src/main/resources/common/message/UpdateFeaturesResponse.json 38 clients/src/main/resources/common/message/UpdateMetadataRequest.json 21 clients/src/main/resources/common/message/UpdateMetadataResponse.json 21 clients/src/main/resources/common/message/UpdateRaftVoterRequest.json 48 clients/src/main/resources/common/message/UpdateRaftVoterResponse.json 37 clients/src/main/resources/common/message/VoteRequest.json 57 clients/src/main/resources/common/message/VoteResponse.json 55 clients/src/main/resources/common/message/VotersRecord.json 47 clients/src/main/resources/common/message/WriteShareGroupStateRequest.json 53 clients/src/main/resources/common/message/WriteShareGroupStateResponse.json 45 clients/src/main/resources/common/message/WriteTxnMarkersRequest.json 45 clients/src/main/resources/common/message/WriteTxnMarkersResponse.json 43 clients/src/test/resources/common/message/NullableStructMessage.json 44 clients/src/test/resources/common/message/SimpleArraysMessage.json 29 clients/src/test/resources/common/message/SimpleExampleMessage.json 66 clients/src/test/resources/common/message/SimpleRecordsMessage.json 26 committer-tools/README.md 71 committer-tools/requirements.txt 19 config/broker.properties 96 config/connect-console-sink.properties 18 config/connect-console-source.properties 18 config/connect-distributed.properties 78 config/connect-file-sink.properties 19 config/connect-file-source.properties 19 config/connect-mirror-maker.properties 49 config/connect-standalone.properties 37 config/consumer.properties 23 config/controller.properties 97 config/producer.properties 36 config/server.properties 98 connect/json/src/test/resources/connect-test.properties 15 docker/README.md 169 docker/examples/README.md 209 docker/examples/fixtures/client-secrets/client-ssl.properties 25 docker/examples/fixtures/file-input/server.properties 32 docker/native/README.md 27 docker/native/native-image-configs/jni-config.json 55 docker/native/native-image-configs/predefined-classes-config.json 7 docker/native/native-image-configs/proxy-config.json 5 docker/native/native-image-configs/resource-config.json 141 docker/native/native-image-configs/serialization-config.json 128 docker/requirements.txt 16 docker/server.properties 105 docker/test/fixtures/file-input/server.properties 32 docker/test/fixtures/secrets/client-ssl.properties 22 examples/README.md 7 examples/src/main/java/kafka/examples/Consumer.java 115 examples/src/main/java/kafka/examples/ExactlyOnceMessageProcessor.java 202 examples/src/main/java/kafka/examples/KafkaConsumerProducerDemo.java 35 examples/src/main/java/kafka/examples/KafkaExactlyOnceDemo.java 76 examples/src/main/java/kafka/examples/KafkaProperties.java 5 examples/src/main/java/kafka/examples/Producer.java 128 examples/src/main/java/kafka/examples/Utils.java 75 gradle.properties 31 group-coordinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentKey.json 27 group-coordinator/src/main/resources/common/message/ConsumerGroupCurrentMemberAssignmentValue.json 41 group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataKey.json 27 group-coordinator/src/main/resources/common/message/ConsumerGroupMemberMetadataValue.json 56 group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataKey.json 25 group-coordinator/src/main/resources/common/message/ConsumerGroupMetadataValue.json 32 group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataKey.json 27 group-coordinator/src/main/resources/common/message/ConsumerGroupPartitionMetadataValue.json 41 group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionKey.json 27 group-coordinator/src/main/resources/common/message/ConsumerGroupRegularExpressionValue.json 26 group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberKey.json 27 group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMemberValue.json 30 group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataKey.json 25 group-coordinator/src/main/resources/common/message/ConsumerGroupTargetAssignmentMetadataValue.json 25 group-coordinator/src/main/resources/common/message/GroupMetadataKey.json 25 group-coordinator/src/main/resources/common/message/GroupMetadataValue.json 62 group-coordinator/src/main/resources/common/message/LegacyOffsetCommitKey.json 29 group-coordinator/src/main/resources/common/message/LegacyOffsetCommitValue.json 29 group-coordinator/src/main/resources/common/message/OffsetCommitKey.json 29 group-coordinator/src/main/resources/common/message/OffsetCommitValue.json 36 group-coordinator/src/main/resources/common/message/ShareGroupCurrentMemberAssignmentKey.json 28 group-coordinator/src/main/resources/common/message/ShareGroupCurrentMemberAssignmentValue.json 40 group-coordinator/src/main/resources/common/message/ShareGroupMemberMetadataKey.json 28 group-coordinator/src/main/resources/common/message/ShareGroupMemberMetadataValue.json 32 group-coordinator/src/main/resources/common/message/ShareGroupMetadataKey.json 26 group-coordinator/src/main/resources/common/message/ShareGroupMetadataValue.json 28 group-coordinator/src/main/resources/common/message/ShareGroupPartitionMetadataKey.json 26 group-coordinator/src/main/resources/common/message/ShareGroupPartitionMetadataValue.json 40 group-coordinator/src/main/resources/common/message/ShareGroupStatePartitionMetadataKey.json 26 group-coordinator/src/main/resources/common/message/ShareGroupStatePartitionMetadataValue.json 46 group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMemberKey.json 28 group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMemberValue.json 31 group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMetadataKey.json 26 group-coordinator/src/main/resources/common/message/ShareGroupTargetAssignmentMetadataValue.json 26 group-coordinator/src/main/resources/common/message/StreamsGroupCurrentMemberAssignmentKey.json 28 group-coordinator/src/main/resources/common/message/StreamsGroupCurrentMemberAssignmentValue.json 50 group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataKey.json 28 group-coordinator/src/main/resources/common/message/StreamsGroupMemberMetadataValue.json 58 group-coordinator/src/main/resources/common/message/StreamsGroupMetadataKey.json 26 group-coordinator/src/main/resources/common/message/StreamsGroupMetadataValue.json 28 group-coordinator/src/main/resources/common/message/StreamsGroupPartitionMetadataKey.json 26 group-coordinator/src/main/resources/common/message/StreamsGroupPartitionMetadataValue.json 33 group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberKey.json 28 group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMemberValue.json 38 group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMetadataKey.json 26 group-coordinator/src/main/resources/common/message/StreamsGroupTargetAssignmentMetadataValue.json 26 group-coordinator/src/main/resources/common/message/StreamsGroupTopologyKey.json 26 group-coordinator/src/main/resources/common/message/StreamsGroupTopologyValue.json 74 jmh-benchmarks/README.md 80 metadata/src/main/resources/common/metadata/AbortTransactionRecord.json 26 metadata/src/main/resources/common/metadata/AccessControlEntryRecord.json 39 metadata/src/main/resources/common/metadata/BeginTransactionRecord.json 26 metadata/src/main/resources/common/metadata/BrokerRegistrationChangeRecord.json 35 metadata/src/main/resources/common/metadata/ClearElrRecord.json 25 metadata/src/main/resources/common/metadata/ClientQuotaRecord.json 36 metadata/src/main/resources/common/metadata/ConfigRecord.json 31 metadata/src/main/resources/common/metadata/DelegationTokenRecord.json 37 metadata/src/main/resources/common/metadata/EndTransactionRecord.json 23 metadata/src/main/resources/common/metadata/FeatureLevelRecord.json 30 metadata/src/main/resources/common/metadata/FenceBrokerRecord.json 27 metadata/src/main/resources/common/metadata/NoOpRecord.json 22 metadata/src/main/resources/common/metadata/PartitionChangeRecord.json 55 metadata/src/main/resources/common/metadata/PartitionRecord.json 53 metadata/src/main/resources/common/metadata/ProducerIdsRecord.json 29 metadata/src/main/resources/common/metadata/RegisterBrokerRecord.json 62 metadata/src/main/resources/common/metadata/RegisterControllerRecord.json 49 metadata/src/main/resources/common/metadata/RemoveAccessControlEntryRecord.json 25 metadata/src/main/resources/common/metadata/RemoveDelegationTokenRecord.json 25 metadata/src/main/resources/common/metadata/RemoveTopicRecord.json 25 metadata/src/main/resources/common/metadata/RemoveUserScramCredentialRecord.json 27 metadata/src/main/resources/common/metadata/TopicRecord.json 27 metadata/src/main/resources/common/metadata/UnfenceBrokerRecord.json 27 metadata/src/main/resources/common/metadata/UnregisterBrokerRecord.json 27 metadata/src/main/resources/common/metadata/UserScramCredentialRecord.json 35 metadata/src/main/resources/common/metadata/ZkMigrationRecord.json 34 raft/README.md 39 raft/config/kraft.properties 19 raft/src/main/resources/common/message/QuorumStateData.json 39 release/README.md 40 release/requirements.txt 18 share-coordinator/src/main/resources/common/message/ShareSnapshotKey.json 30 share-coordinator/src/main/resources/common/message/ShareSnapshotValue.json 47 share-coordinator/src/main/resources/common/message/ShareUpdateKey.json 30 share-coordinator/src/main/resources/common/message/ShareUpdateValue.json 41 storage/src/main/resources/message/ProducerSnapshot.json 84 storage/src/main/resources/message/RemoteLogSegmentMetadataRecord.json 141 storage/src/main/resources/message/RemoteLogSegmentMetadataSnapshotRecord.json 107 storage/src/main/resources/message/RemoteLogSegmentMetadataUpdateRecord.json 89 storage/src/main/resources/message/RemotePartitionDeleteMetadataRecord.json 67 storage/src/test/java/org/apache/kafka/tiered/storage/README.md 6 streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/JsonTimestampExtractor.java 19 streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewTypedDemo.java 157 streams/examples/src/main/java/org/apache/kafka/streams/examples/pageview/PageViewUntypedDemo.java 67 streams/examples/src/main/java/org/apache/kafka/streams/examples/pipe/PipeDemo.java 36 streams/examples/src/main/java/org/apache/kafka/streams/examples/temperature/TemperatureDemo.java 62 streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountDemo.java 66 streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorDemo.java 96 streams/examples/src/main/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerDemo.java 104 streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java 83 streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountProcessorTest.java 35 streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountTransformerTest.java 56 streams/quickstart/java/src/test/resources/projects/basic/archetype.properties 18 streams/quickstart/java/src/test/resources/projects/basic/goal.txt 1 streams/src/main/resources/common/message/SubscriptionInfoData.json 182 streams/src/test/resources/kafka/kafka-streams-version.properties 16 test-common/test-common-internal-api/src/main/java/org/apache/kafka/common/test/api/README.md 150 test-common/test-common-util/src/main/resources/junit-platform.properties 16 tests/README.md 254 tests/docker/requirements.txt 24 tests/kafkatest/services/kafka/templates/kafka.properties 118 tests/kafkatest/services/kafka/templates/log4j.properties 119 tests/kafkatest/services/performance/templates/tools_log4j.properties 23 tests/kafkatest/services/security/templates/minikdc.properties 15 tests/kafkatest/services/templates/connect_log4j.properties 30 tests/kafkatest/services/templates/console_consumer.properties 21 tests/kafkatest/services/templates/mirror_maker_consumer.properties 23 tests/kafkatest/services/templates/mirror_maker_producer.properties 18 tests/kafkatest/services/templates/producer.properties 16 tests/kafkatest/services/templates/tools_log4j.properties 28 tests/kafkatest/services/templates/zookeeper.properties 43 tests/kafkatest/services/trogdor/templates/log4j.properties 22 tests/kafkatest/tests/connect/templates/connect-distributed.properties 56 tests/kafkatest/tests/connect/templates/connect-file-external.properties 15 tests/kafkatest/tests/connect/templates/connect-file-sink.properties 38 tests/kafkatest/tests/connect/templates/connect-file-source.properties 31 tests/kafkatest/tests/connect/templates/connect-standalone.properties 38 tests/kafkatest/tests/streams/templates/log4j_template.properties 28 tests/spec/connection_stress_test.json 27 tests/spec/external_command.json 31 tests/spec/round_trip.json 32 tests/spec/share_round_trip.json 32 tests/spec/simple_consume_bench_spec.json 29 tests/spec/simple_produce_bench.json 38 tests/spec/simple_share_consume_bench_spec.json 29 tests/spec/transactional-produce-bench.json 42 transaction-coordinator/src/main/resources/common/message/TransactionLogKey.json 25 transaction-coordinator/src/main/resources/common/message/TransactionLogValue.json 52 trogdor/README.md 157 vagrant/README.md 95