- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.py files (139): release_notes.py release.py tests/unit/directory_layout/__init__.py tests/unit/directory_layout/check_project_paths.py tests/unit/__init__.py tests/unit/version/__init__.py tests/unit/version/check_version.py tests/bin/external_trogdor_command_example.py tests/setup.py tests/kafkatest/directory_layout/__init__.py tests/kafkatest/directory_layout/kafka_path.py tests/kafkatest/version.py tests/kafkatest/sanity_checks/__init__.py tests/kafkatest/sanity_checks/test_verifiable_producer.py tests/kafkatest/sanity_checks/test_kafka_version.py tests/kafkatest/sanity_checks/test_performance_services.py tests/kafkatest/sanity_checks/test_console_consumer.py tests/kafkatest/tests/tools/log_compaction_test.py tests/kafkatest/tests/tools/trogdor_test.py tests/kafkatest/tests/tools/__init__.py tests/kafkatest/tests/tools/kibosh_test.py tests/kafkatest/tests/tools/log4j_appender_test.py tests/kafkatest/tests/tools/replica_verification_test.py tests/kafkatest/tests/core/fetch_from_follower_test.py tests/kafkatest/tests/core/transactions_test.py tests/kafkatest/tests/core/zookeeper_tls_test.py tests/kafkatest/tests/core/mirror_maker_test.py tests/kafkatest/tests/core/security_test.py tests/kafkatest/tests/core/produce_bench_test.py tests/kafkatest/tests/core/replica_scale_test.py tests/kafkatest/tests/core/security_rolling_upgrade_test.py tests/kafkatest/tests/core/delegation_token_test.py tests/kafkatest/tests/core/zookeeper_security_upgrade_test.py tests/kafkatest/tests/core/consumer_group_command_test.py tests/kafkatest/tests/core/log_dir_failure_test.py tests/kafkatest/tests/core/__init__.py tests/kafkatest/tests/core/throttling_test.py tests/kafkatest/tests/core/round_trip_fault_test.py tests/kafkatest/tests/core/consume_bench_test.py tests/kafkatest/tests/core/network_degrade_test.py tests/kafkatest/tests/core/replication_test.py tests/kafkatest/tests/core/zookeeper_tls_encrypt_only_test.py tests/kafkatest/tests/core/compatibility_test_new_broker_test.py tests/kafkatest/tests/core/upgrade_test.py tests/kafkatest/tests/core/group_mode_transactions_test.py tests/kafkatest/tests/core/reassign_partitions_test.py tests/kafkatest/tests/core/get_offset_shell_test.py tests/kafkatest/tests/core/downgrade_test.py tests/kafkatest/tests/kafka_test.py tests/kafkatest/tests/streams/streams_shutdown_deadlock_test.py tests/kafkatest/tests/streams/streams_standby_replica_test.py tests/kafkatest/tests/streams/base_streams_test.py tests/kafkatest/tests/streams/streams_named_repartition_topic_test.py tests/kafkatest/tests/streams/streams_eos_test.py tests/kafkatest/tests/streams/__init__.py tests/kafkatest/tests/streams/utils/util.py tests/kafkatest/tests/streams/utils/__init__.py tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py tests/kafkatest/tests/streams/streams_static_membership_test.py tests/kafkatest/tests/streams/streams_upgrade_test.py tests/kafkatest/tests/streams/streams_broker_compatibility_test.py tests/kafkatest/tests/streams/streams_application_upgrade_test.py tests/kafkatest/tests/streams/streams_broker_bounce_test.py tests/kafkatest/tests/streams/streams_relational_smoke_test.py tests/kafkatest/tests/streams/streams_optimized_test.py tests/kafkatest/tests/streams/streams_cooperative_rebalance_upgrade_test.py tests/kafkatest/tests/streams/streams_smoke_test.py tests/kafkatest/tests/__init__.py tests/kafkatest/tests/produce_consume_validate.py tests/kafkatest/tests/end_to_end.py tests/kafkatest/tests/verifiable_consumer_test.py tests/kafkatest/tests/connect/__init__.py tests/kafkatest/tests/connect/connect_distributed_test.py tests/kafkatest/tests/connect/connect_rest_test.py tests/kafkatest/tests/connect/connect_test.py tests/kafkatest/tests/client/client_compatibility_features_test.py tests/kafkatest/tests/client/compression_test.py tests/kafkatest/tests/client/message_format_change_test.py tests/kafkatest/tests/client/__init__.py tests/kafkatest/tests/client/consumer_test.py tests/kafkatest/tests/client/truncation_test.py tests/kafkatest/tests/client/consumer_rolling_upgrade_test.py tests/kafkatest/tests/client/pluggable_test.py tests/kafkatest/tests/client/quota_test.py tests/kafkatest/tests/client/client_compatibility_produce_consume_test.py tests/kafkatest/__init__.py tests/kafkatest/utils/util.py tests/kafkatest/utils/__init__.py tests/kafkatest/utils/remote_account.py tests/kafkatest/benchmarks/core/__init__.py tests/kafkatest/benchmarks/core/benchmark_test.py tests/kafkatest/benchmarks/__init__.py tests/kafkatest/services/replica_verification_tool.py tests/kafkatest/services/kafka_log4j_appender.py tests/kafkatest/services/transactional_message_copier.py tests/kafkatest/services/monitor/__init__.py tests/kafkatest/services/monitor/jmx.py tests/kafkatest/services/monitor/http.py tests/kafkatest/services/streams.py tests/kafkatest/services/verifiable_client.py tests/kafkatest/services/console_consumer.py tests/kafkatest/services/connect.py tests/kafkatest/services/log_compaction_tester.py tests/kafkatest/services/security/__init__.py tests/kafkatest/services/security/listener_security_config.py tests/kafkatest/services/security/kafka_acls.py tests/kafkatest/services/security/minikdc.py tests/kafkatest/services/security/security_config.py tests/kafkatest/services/trogdor/files_unreadable_fault_spec.py tests/kafkatest/services/trogdor/degraded_network_fault_spec.py tests/kafkatest/services/trogdor/network_partition_fault_spec.py tests/kafkatest/services/trogdor/produce_bench_workload.py tests/kafkatest/services/trogdor/process_stop_fault_spec.py tests/kafkatest/services/trogdor/__init__.py tests/kafkatest/services/trogdor/consume_bench_workload.py tests/kafkatest/services/trogdor/kibosh.py tests/kafkatest/services/trogdor/trogdor.py tests/kafkatest/services/trogdor/round_trip_workload.py tests/kafkatest/services/trogdor/task_spec.py tests/kafkatest/services/trogdor/no_op_task_spec.py tests/kafkatest/services/consumer_property.py tests/kafkatest/services/zookeeper.py tests/kafkatest/services/delegation_tokens.py tests/kafkatest/services/__init__.py tests/kafkatest/services/mirror_maker.py tests/kafkatest/services/verifiable_consumer.py tests/kafkatest/services/verifiable_producer.py tests/kafkatest/services/streams_property.py tests/kafkatest/services/kafka/config_property.py tests/kafkatest/services/kafka/config.py tests/kafkatest/services/kafka/util.py tests/kafkatest/services/kafka/__init__.py tests/kafkatest/services/kafka/kafka.py tests/kafkatest/services/performance/producer_performance.py tests/kafkatest/services/performance/__init__.py tests/kafkatest/services/performance/end_to_end_latency.py tests/kafkatest/services/performance/performance.py tests/kafkatest/services/performance/consumer_performance.py kafka-merge-pr.py - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.json files (115): clients/src/test/resources/common/message/SimpleExampleMessage.json clients/src/test/resources/common/message/SimpleRecordsMessage.json clients/src/main/resources/common/message/DescribeDelegationTokenRequest.json clients/src/main/resources/common/message/DeleteRecordsRequest.json clients/src/main/resources/common/message/CreateDelegationTokenResponse.json clients/src/main/resources/common/message/MetadataRequest.json clients/src/main/resources/common/message/HeartbeatResponse.json clients/src/main/resources/common/message/StopReplicaRequest.json clients/src/main/resources/common/message/ProduceRequest.json clients/src/main/resources/common/message/DeleteGroupsRequest.json clients/src/main/resources/common/message/EndTxnRequest.json clients/src/main/resources/common/message/AlterClientQuotasRequest.json clients/src/main/resources/common/message/UpdateMetadataRequest.json clients/src/main/resources/common/message/DescribeGroupsResponse.json clients/src/main/resources/common/message/LeaveGroupResponse.json clients/src/main/resources/common/message/DescribeUserScramCredentialsRequest.json clients/src/main/resources/common/message/FindCoordinatorRequest.json clients/src/main/resources/common/message/AddPartitionsToTxnRequest.json clients/src/main/resources/common/message/SaslHandshakeRequest.json clients/src/main/resources/common/message/DescribeLogDirsRequest.json clients/src/main/resources/common/message/FetchRequest.json clients/src/main/resources/common/message/AlterReplicaLogDirsRequest.json clients/src/main/resources/common/message/DescribeUserScramCredentialsResponse.json clients/src/main/resources/common/message/ResponseHeader.json clients/src/main/resources/common/message/AlterPartitionReassignmentsResponse.json clients/src/main/resources/common/message/ApiVersionsResponse.json clients/src/main/resources/common/message/LeaderAndIsrResponse.json clients/src/main/resources/common/message/CreatePartitionsResponse.json clients/src/main/resources/common/message/SyncGroupResponse.json clients/src/main/resources/common/message/DeleteGroupsResponse.json clients/src/main/resources/common/message/OffsetFetchResponse.json clients/src/main/resources/common/message/DeleteRecordsResponse.json clients/src/main/resources/common/message/UpdateMetadataResponse.json clients/src/main/resources/common/message/CreateAclsResponse.json clients/src/main/resources/common/message/AlterConfigsResponse.json clients/src/main/resources/common/message/ElectLeadersResponse.json clients/src/main/resources/common/message/FetchResponse.json clients/src/main/resources/common/message/SaslAuthenticateResponse.json clients/src/main/resources/common/message/ListPartitionReassignmentsResponse.json clients/src/main/resources/common/message/ListGroupsRequest.json clients/src/main/resources/common/message/HeartbeatRequest.json clients/src/main/resources/common/message/ElectLeadersRequest.json clients/src/main/resources/common/message/DescribeConfigsResponse.json clients/src/main/resources/common/message/IncrementalAlterConfigsRequest.json clients/src/main/resources/common/message/LeaveGroupRequest.json clients/src/main/resources/common/message/MetadataResponse.json clients/src/main/resources/common/message/WriteTxnMarkersRequest.json clients/src/main/resources/common/message/InitProducerIdRequest.json clients/src/main/resources/common/message/AlterConfigsRequest.json clients/src/main/resources/common/message/ListPartitionReassignmentsRequest.json clients/src/main/resources/common/message/DescribeAclsResponse.json clients/src/main/resources/common/message/OffsetDeleteRequest.json clients/src/main/resources/common/message/EndTxnResponse.json clients/src/main/resources/common/message/ControlledShutdownResponse.json clients/src/main/resources/common/message/DeleteTopicsRequest.json clients/src/main/resources/common/message/WriteTxnMarkersResponse.json clients/src/main/resources/common/message/ApiVersionsRequest.json clients/src/main/resources/common/message/AlterClientQuotasResponse.json clients/src/main/resources/common/message/CreateDelegationTokenRequest.json clients/src/main/resources/common/message/ListOffsetResponse.json clients/src/main/resources/common/message/AlterReplicaLogDirsResponse.json clients/src/main/resources/common/message/SaslHandshakeResponse.json clients/src/main/resources/common/message/ListOffsetRequest.json clients/src/main/resources/common/message/DeleteAclsResponse.json clients/src/main/resources/common/message/OffsetDeleteResponse.json clients/src/main/resources/common/message/JoinGroupRequest.json clients/src/main/resources/common/message/AlterUserScramCredentialsRequest.json clients/src/main/resources/common/message/FindCoordinatorResponse.json clients/src/main/resources/common/message/InitProducerIdResponse.json clients/src/main/resources/common/message/CreateAclsRequest.json clients/src/main/resources/common/message/DeleteAclsRequest.json clients/src/main/resources/common/message/AlterPartitionReassignmentsRequest.json clients/src/main/resources/common/message/TxnOffsetCommitRequest.json clients/src/main/resources/common/message/DescribeAclsRequest.json clients/src/main/resources/common/message/JoinGroupResponse.json clients/src/main/resources/common/message/OffsetForLeaderEpochRequest.json clients/src/main/resources/common/message/DescribeClientQuotasResponse.json clients/src/main/resources/common/message/IncrementalAlterConfigsResponse.json clients/src/main/resources/common/message/OffsetForLeaderEpochResponse.json clients/src/main/resources/common/message/SaslAuthenticateRequest.json clients/src/main/resources/common/message/AlterUserScramCredentialsResponse.json clients/src/main/resources/common/message/ExpireDelegationTokenResponse.json clients/src/main/resources/common/message/OffsetFetchRequest.json clients/src/main/resources/common/message/DescribeLogDirsResponse.json clients/src/main/resources/common/message/ExpireDelegationTokenRequest.json clients/src/main/resources/common/message/DescribeClientQuotasRequest.json clients/src/main/resources/common/message/DeleteTopicsResponse.json clients/src/main/resources/common/message/SyncGroupRequest.json clients/src/main/resources/common/message/StopReplicaResponse.json clients/src/main/resources/common/message/CreateTopicsRequest.json clients/src/main/resources/common/message/RequestHeader.json clients/src/main/resources/common/message/ProduceResponse.json clients/src/main/resources/common/message/AddOffsetsToTxnRequest.json clients/src/main/resources/common/message/CreateTopicsResponse.json clients/src/main/resources/common/message/ListGroupsResponse.json clients/src/main/resources/common/message/DescribeDelegationTokenResponse.json clients/src/main/resources/common/message/CreatePartitionsRequest.json clients/src/main/resources/common/message/LeaderAndIsrRequest.json clients/src/main/resources/common/message/TxnOffsetCommitResponse.json clients/src/main/resources/common/message/AddOffsetsToTxnResponse.json clients/src/main/resources/common/message/RenewDelegationTokenRequest.json clients/src/main/resources/common/message/ControlledShutdownRequest.json clients/src/main/resources/common/message/DescribeConfigsRequest.json clients/src/main/resources/common/message/OffsetCommitRequest.json clients/src/main/resources/common/message/DescribeGroupsRequest.json clients/src/main/resources/common/message/OffsetCommitResponse.json clients/src/main/resources/common/message/AddPartitionsToTxnResponse.json clients/src/main/resources/common/message/RenewDelegationTokenResponse.json streams/src/main/resources/common/message/SubscriptionInfoData.json tests/spec/external_command.json tests/spec/connection_stress_test.json tests/spec/transactional-produce-bench.json tests/spec/simple_produce_bench.json tests/spec/simple_consume_bench_spec.json tests/spec/round_trip.json - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.html files (60): core/src/main/scala/kafka/network/package.html core/src/main/scala/kafka/server/package.html core/src/main/scala/kafka/log/package.html docs/quickstart.html docs/ops.html docs/documentation.html docs/design.html docs/documentation/index.html docs/documentation/streams/quickstart.html docs/documentation/streams/tutorial.html docs/documentation/streams/index.html docs/documentation/streams/architecture.html docs/documentation/streams/core-concepts.html docs/documentation/streams/upgrade-guide.html docs/documentation/streams/developer-guide/write-streams.html docs/documentation/streams/developer-guide/dsl-api.html docs/documentation/streams/developer-guide/dsl-topology-naming.html docs/documentation/streams/developer-guide/index.html docs/documentation/streams/developer-guide/memory-mgmt.html docs/documentation/streams/developer-guide/config-streams.html docs/documentation/streams/developer-guide/processor-api.html docs/documentation/streams/developer-guide/manage-topics.html docs/documentation/streams/developer-guide/app-reset-tool.html docs/documentation/streams/developer-guide/running-app.html docs/documentation/streams/developer-guide/security.html docs/documentation/streams/developer-guide/datatypes.html docs/documentation/streams/developer-guide/testing.html docs/documentation/streams/developer-guide/interactive-queries.html docs/ecosystem.html docs/toc.html docs/protocol.html docs/streams/quickstart.html docs/streams/tutorial.html docs/streams/index.html docs/streams/architecture.html docs/streams/core-concepts.html docs/streams/upgrade-guide.html docs/streams/developer-guide/write-streams.html docs/streams/developer-guide/dsl-api.html docs/streams/developer-guide/dsl-topology-naming.html docs/streams/developer-guide/index.html docs/streams/developer-guide/memory-mgmt.html docs/streams/developer-guide/config-streams.html docs/streams/developer-guide/processor-api.html docs/streams/developer-guide/manage-topics.html docs/streams/developer-guide/app-reset-tool.html docs/streams/developer-guide/running-app.html docs/streams/developer-guide/security.html docs/streams/developer-guide/datatypes.html docs/streams/developer-guide/testing.html docs/streams/developer-guide/interactive-queries.html docs/configuration.html docs/uses.html docs/upgrade.html docs/security.html docs/migration.html docs/implementation.html docs/api.html docs/introduction.html docs/connect.html - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.properties files (47): clients/src/test/resources/log4j.properties tools/src/test/resources/log4j.properties core/src/test/resources/log4j.properties core/src/test/scala/other/kafka.log4j.properties config/consumer.properties config/connect-mirror-maker.properties config/zookeeper.properties config/server.properties config/producer.properties config/connect-console-sink.properties config/connect-log4j.properties config/connect-standalone.properties config/connect-file-source.properties config/connect-console-source.properties config/connect-distributed.properties config/tools-log4j.properties config/connect-file-sink.properties config/log4j.properties streams/test-utils/src/test/resources/log4j.properties streams/streams-scala/src/test/resources/log4j.properties streams/quickstart/java/src/test/resources/projects/basic/archetype.properties streams/quickstart/java/src/main/resources/archetype-resources/src/main/resources/log4j.properties streams/src/test/resources/kafka/kafka-streams-version.properties streams/src/test/resources/log4j.properties tests/kafkatest/tests/streams/templates/log4j_template.properties tests/kafkatest/tests/connect/templates/connect-file-external.properties tests/kafkatest/tests/connect/templates/connect-standalone.properties tests/kafkatest/tests/connect/templates/connect-file-source.properties tests/kafkatest/tests/connect/templates/connect-distributed.properties tests/kafkatest/tests/connect/templates/connect-file-sink.properties tests/kafkatest/services/security/templates/minikdc.properties tests/kafkatest/services/trogdor/templates/log4j.properties tests/kafkatest/services/kafka/templates/kafka.properties tests/kafkatest/services/kafka/templates/log4j.properties tests/kafkatest/services/templates/connect_log4j.properties tests/kafkatest/services/templates/zookeeper.properties tests/kafkatest/services/templates/producer.properties tests/kafkatest/services/templates/tools_log4j.properties tests/kafkatest/services/templates/console_consumer.properties tests/kafkatest/services/templates/mirror_maker_consumer.properties tests/kafkatest/services/templates/mirror_maker_producer.properties tests/kafkatest/services/performance/templates/tools_log4j.properties gradle/wrapper/gradle-wrapper.properties gradle.properties connect/runtime/src/test/resources/log4j.properties connect/json/src/test/resources/connect-test.properties connect/mirror/src/test/resources/log4j.properties - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.sh files (46): bin/kafka-delete-records.sh bin/trogdor.sh bin/kafka-preferred-replica-election.sh bin/connect-mirror-maker.sh bin/kafka-console-consumer.sh bin/kafka-consumer-perf-test.sh bin/kafka-log-dirs.sh bin/zookeeper-server-stop.sh bin/kafka-verifiable-consumer.sh bin/kafka-acls.sh bin/zookeeper-server-start.sh bin/kafka-server-stop.sh bin/kafka-configs.sh bin/kafka-reassign-partitions.sh bin/kafka-leader-election.sh bin/kafka-producer-perf-test.sh bin/kafka-topics.sh bin/connect-standalone.sh bin/kafka-dump-log.sh bin/kafka-broker-api-versions.sh bin/kafka-consumer-groups.sh bin/connect-distributed.sh bin/kafka-delegation-tokens.sh bin/kafka-run-class.sh bin/kafka-replica-verification.sh bin/kafka-console-producer.sh bin/zookeeper-shell.sh bin/kafka-verifiable-producer.sh bin/kafka-server-start.sh bin/kafka-mirror-maker.sh bin/kafka-streams-application-reset.sh bin/zookeeper-security-migration.sh jenkins.sh vagrant/package-base-box.sh vagrant/broker.sh vagrant/base.sh vagrant/vagrant-up.sh vagrant/aws/aws-init.sh vagrant/zk.sh install.sh tests/docker/run_tests.sh tests/bin/flatten_html.sh tests/bootstrap-test-env.sh jmh-benchmarks/jmh.sh examples/bin/java-producer-consumer-demo.sh examples/bin/exactly-once-demo.sh - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.png files (43): docs/images/tracking_high_level.png docs/images/kafka-apis.png docs/images/log_compaction.png docs/images/streams-interactive-queries-03.png docs/images/streams-interactive-queries-api-02.png docs/images/streams-interactive-queries-02.png docs/images/streams-interactive-queries-api-01.png docs/images/kafka_multidc_complex.png docs/images/streams-time-windows-tumbling.png docs/images/streams-interactive-queries-01.png docs/images/streams-table-duality-01.png docs/images/producer_consumer.png docs/images/streams-table-duality-02.png docs/images/streams-table-duality-03.png docs/images/streams-sliding-windows.png docs/images/consumer-groups.png docs/images/kafka_log.png docs/images/mirror-maker.png docs/images/log_consumer.png docs/images/streams-session-windows-02.png docs/images/icons/rabobank.png docs/images/icons/zalando.png docs/images/icons/documentation.png docs/images/icons/documentation--white.png docs/images/icons/architecture--white.png docs/images/icons/new-york.png docs/images/icons/tutorials--white.png docs/images/icons/line.png docs/images/icons/tutorials.png docs/images/icons/architecture.png docs/images/kafka_multidc.png docs/images/streams-welcome.png docs/images/streams-stateful_operations.png docs/images/log_cleaner_anatomy.png docs/images/streams-session-windows-01.png docs/images/streams-table-updates-01.png docs/images/streams-time-windows-hopping.png docs/images/log_anatomy.png docs/images/streams-table-updates-02.png docs/images/streams-elastic-scaling-1.png docs/images/streams-elastic-scaling-3.png docs/images/streams-cache-and-commit-interval.png docs/images/streams-elastic-scaling-2.png - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.bat files (27): bin/windows/kafka-log-dirs.bat bin/windows/zookeeper-server-stop.bat bin/windows/connect-distributed.bat bin/windows/kafka-configs.bat bin/windows/kafka-console-producer.bat bin/windows/kafka-delete-records.bat bin/windows/kafka-topics.bat bin/windows/kafka-dump-log.bat bin/windows/kafka-console-consumer.bat bin/windows/kafka-preferred-replica-election.bat bin/windows/kafka-server-start.bat bin/windows/kafka-consumer-groups.bat bin/windows/kafka-mirror-maker.bat bin/windows/kafka-reassign-partitions.bat bin/windows/kafka-producer-perf-test.bat bin/windows/zookeeper-server-start.bat bin/windows/kafka-server-stop.bat bin/windows/kafka-replica-verification.bat bin/windows/kafka-run-class.bat bin/windows/kafka-acls.bat bin/windows/kafka-delegation-tokens.bat bin/windows/kafka-broker-api-versions.bat bin/windows/kafka-leader-election.bat bin/windows/kafka-streams-application-reset.bat bin/windows/zookeeper-shell.bat bin/windows/connect-standalone.bat bin/windows/kafka-consumer-perf-test.bat - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *. files (19): clients/src/test/resources/serializedData/offsetAndMetadataBeforeLeaderEpoch clients/src/test/resources/serializedData/topicPartitionSerializedfile clients/src/test/resources/serializedData/offsetAndMetadataWithLeaderEpoch LICENSE vagrant/aws/aws-access-keys-commands streams/streams-scala/NOTICE tests/docker/ducker-ak tests/docker/Dockerfile tests/docker/ssh/config tests/docker/ssh/id_rsa tests/docker/ssh/authorized_keys tests/docker/ssh-config NOTICE gradlew examples/README Jenkinsfile Vagrantfile gradlewAll HEADER - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.xml files (10): checkstyle/import-control-core.xml checkstyle/import-control-jmh-benchmarks.xml checkstyle/import-control.xml checkstyle/suppressions.xml checkstyle/checkstyle.xml streams/quickstart/pom.xml streams/quickstart/java/pom.xml streams/quickstart/java/src/main/resources/META-INF/maven/archetype-metadata.xml streams/quickstart/java/src/main/resources/archetype-resources/pom.xml gradle/spotbugs-exclude.xml - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.md files (9): clients/src/main/resources/common/message/README.md TROGDOR.md vagrant/README.md tests/README.md PULL_REQUEST_TEMPLATE.md README.md jmh-benchmarks/README.md CONTRIBUTING.md connect/mirror/README.md - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.jpg files (7): docs/images/streams-architecture-topology.jpg docs/images/streams-architecture-overview.jpg docs/images/streams-architecture-threads.jpg docs/images/icons/NYT.jpg docs/images/streams-architecture-tasks.jpg docs/images/streams-concepts-topology.jpg docs/images/streams-architecture-states.jpg - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.gitignore files (7): clients/.gitignore core/.gitignore streams/streams-scala/.gitignore streams/.gitignore tests/.gitignore connect/json/.gitignore connect/api/.gitignore - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.gradle files (6): gradle/dependencies.gradle gradle/buildscript.gradle gradle/rat.gradle build.gradle settings.gradle wrapper.gradle - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.conf files (5): checkstyle/.scalafmt.conf core/src/test/resources/minikdc-krb5.conf config/trogdor.conf tests/kafkatest/services/security/templates/admin_client_as_broker_jaas.conf tests/kafkatest/services/security/templates/jaas.conf - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.ConfigProvider files (2): clients/src/main/resources/META-INF/services/org.apache.kafka.common.config.provider.ConfigProvider connect/runtime/src/test/resources/test-plugins/sampling-config-provider/META-INF/services/org.apache.kafka.common.config.provider.ConfigProvider - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.local files (2): vagrant/system-test-Vagrantfile.local vagrant/aws/aws-example-Vagrantfile.local - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.cfg files (2): tests/unit/setup.cfg tests/setup.cfg - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.ConnectRestExtension files (2): connect/runtime/src/test/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension connect/basic-auth-extension/src/main/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.txt files (2): streams/quickstart/java/src/test/resources/projects/basic/goal.txt git-history.txt - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.ServiceLoadedClass files (1): connect/runtime/src/test/resources/test-plugins/service-loader/META-INF/services/test.plugins.ServiceLoadedClass - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.js files (1): docs/js/templateData.js - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.xsl files (1): gradle/resources/rat-output-to-html.xsl - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.ldiff files (1): core/src/test/resources/minikdc.ldiff - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.in files (1): tests/MANIFEST.in - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.ConnectorClientConfigOverridePolicy files (1): connect/runtime/src/main/resources/META-INF/services/org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.rdf files (1): doap_Kafka.rdf - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.header files (1): checkstyle/java.header - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.pub files (1): tests/docker/ssh/id_rsa.pub - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -