pulsar-admin-sdk 2.2.0

This provides the REST API for admin operations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131

# WorkerConfig

## Properties

Name | Type | Description | Notes
------------ | ------------- | ------------- | -------------
**additional_java_runtime_arguments** | Option<**Vec<String>**> |  | [optional]
**assignment_write_max_retries** | Option<**i32**> |  | [optional]
**authenticate_metrics_endpoint** | Option<**bool**> |  | [optional]
**authentication_enabled** | Option<**bool**> |  | [optional]
**authentication_providers** | Option<**Vec<String>**> |  | [optional]
**authorization_enabled** | Option<**bool**> |  | [optional]
**authorization_provider** | Option<**String**> |  | [optional]
**bookkeeper_client_authentication_parameters** | Option<**String**> |  | [optional]
**bookkeeper_client_authentication_parameters_name** | Option<**String**> |  | [optional]
**bookkeeper_client_authentication_plugin** | Option<**String**> |  | [optional]
**broker_client_authentication_enabled** | Option<**bool**> |  | [optional]
**broker_client_authentication_parameters** | Option<**String**> |  | [optional]
**broker_client_authentication_plugin** | Option<**String**> |  | [optional]
**broker_client_trust_certs_file_path** | Option<**String**> |  | [optional]
**client_authentication_parameters** | Option<**String**> |  | [optional]
**client_authentication_plugin** | Option<**String**> |  | [optional]
**cluster_coordination_topic** | Option<**String**> |  | [optional]
**cluster_coordination_topic_name** | Option<**String**> |  | [optional]
**configuration_metadata_store_url** | Option<**String**> |  | [optional]
**configuration_store_servers** | Option<**String**> |  | [optional]
**connectors_directory** | Option<**String**> |  | [optional]
**download_directory** | Option<**String**> |  | [optional]
**enable_classloading_of_builtin_files** | Option<**bool**> |  | [optional]
**enable_classloading_of_external_files** | Option<**bool**> |  | [optional]
**expose_admin_client_enabled** | Option<**bool**> |  | [optional]
**failure_check_freq_ms** | Option<**i64**> |  | [optional]
**forward_source_message_property** | Option<**bool**> |  | [optional]
**function_assignment_topic** | Option<**String**> |  | [optional]
**function_assignment_topic_name** | Option<**String**> |  | [optional]
**function_auth_provider_class_name** | Option<**String**> |  | [optional]
**function_instance_max_resources** | Option<[**models::Resources**](Resources.md)> |  | [optional]
**function_instance_min_resources** | Option<[**models::Resources**](Resources.md)> |  | [optional]
**function_instance_resource_change_in_lock_step** | Option<**bool**> |  | [optional]
**function_instance_resource_granularities** | Option<[**models::Resources**](Resources.md)> |  | [optional]
**function_metadata_topic** | Option<**String**> |  | [optional]
**function_metadata_topic_name** | Option<**String**> |  | [optional]
**function_runtime_factory_class_name** | Option<**String**> |  | [optional]
**function_runtime_factory_configs** | Option<[**std::collections::HashMap<String, serde_json::Value>**](serde_json::Value.md)> |  | [optional]
**function_web_service_url** | Option<**String**> |  | [optional]
**functions_directory** | Option<**String**> |  | [optional]
**functions_worker_enable_package_management** | Option<**bool**> |  | [optional]
**functions_worker_service_custom_configs** | Option<[**std::collections::HashMap<String, serde_json::Value>**](serde_json::Value.md)> |  | [optional]
**functions_worker_service_nar_package** | Option<**String**> |  | [optional]
**http_requests_limit_enabled** | Option<**bool**> |  | [optional]
**http_requests_max_per_second** | Option<**f64**> |  | [optional]
**http_server_accept_queue_size** | Option<**i32**> |  | [optional]
**http_server_thread_pool_queue_size** | Option<**i32**> |  | [optional]
**ignore_unknown_config_fields** | Option<**bool**> |  | [optional]
**include_standard_prometheus_metrics** | Option<**bool**> |  | [optional]
**initial_broker_reconnect_max_retries** | Option<**i32**> |  | [optional]
**initialized_dlog_metadata** | Option<**bool**> |  | [optional]
**instance_liveness_check_freq_ms** | Option<**i64**> |  | [optional]
**jvm_gc_metrics_logger_class_name** | Option<**String**> |  | [optional]
**kinit_command** | Option<**String**> |  | [optional]
**kubernetes_container_factory** | Option<[**models::KubernetesContainerFactory**](KubernetesContainerFactory.md)> |  | [optional]
**max_concurrent_http_requests** | Option<**i32**> |  | [optional]
**max_http_server_connections** | Option<**i32**> |  | [optional]
**max_pending_async_requests** | Option<**i32**> |  | [optional]
**metadata_store_allow_read_only_operations** | Option<**bool**> |  | [optional]
**metadata_store_cache_expiry_seconds** | Option<**i32**> |  | [optional]
**metadata_store_operation_timeout_seconds** | Option<**i32**> |  | [optional]
**metadata_store_session_timeout_millis** | Option<**i64**> |  | [optional]
**nar_extraction_directory** | Option<**String**> |  | [optional]
**num_function_package_replicas** | Option<**i32**> |  | [optional]
**num_http_server_threads** | Option<**i32**> |  | [optional]
**process_container_factory** | Option<[**models::ProcessContainerFactory**](ProcessContainerFactory.md)> |  | [optional]
**properties** | Option<**std::collections::HashMap<String, String>**> |  | [optional]
**proxy_roles** | Option<**Vec<String>**> |  | [optional]
**pulsar_functions_cluster** | Option<**String**> |  | [optional]
**pulsar_functions_namespace** | Option<**String**> |  | [optional]
**pulsar_service_url** | Option<**String**> |  | [optional]
**pulsar_web_service_url** | Option<**String**> |  | [optional]
**rebalance_check_freq_sec** | Option<**i64**> |  | [optional]
**reschedule_timeout_ms** | Option<**i64**> |  | [optional]
**runtime_customizer_class_name** | Option<**String**> |  | [optional]
**runtime_customizer_config** | Option<[**std::collections::HashMap<String, serde_json::Value>**](serde_json::Value.md)> |  | [optional]
**sasl_jaas_client_allowed_ids** | Option<**String**> |  | [optional]
**sasl_jaas_server_role_token_signer_secret_path** | Option<**String**> |  | [optional]
**sasl_jaas_server_section_name** | Option<**String**> |  | [optional]
**scheduler_class_name** | Option<**String**> |  | [optional]
**secrets_provider_configurator_class_name** | Option<**String**> |  | [optional]
**secrets_provider_configurator_config** | Option<**std::collections::HashMap<String, String>**> |  | [optional]
**state_storage_provider_implementation** | Option<**String**> |  | [optional]
**state_storage_service_url** | Option<**String**> |  | [optional]
**super_user_roles** | Option<**Vec<String>**> |  | [optional]
**thread_container_factory** | Option<[**models::ThreadContainerFactory**](ThreadContainerFactory.md)> |  | [optional]
**tls_allow_insecure_connection** | Option<**bool**> |  | [optional]
**tls_cert_refresh_check_duration_sec** | Option<**i64**> |  | [optional]
**tls_certificate_file_path** | Option<**String**> |  | [optional]
**tls_enable_hostname_verification** | Option<**bool**> |  | [optional]
**tls_enabled** | Option<**bool**> |  | [optional]
**tls_enabled_with_key_store** | Option<**bool**> |  | [optional]
**tls_key_file_path** | Option<**String**> |  | [optional]
**tls_key_store** | Option<**String**> |  | [optional]
**tls_key_store_password** | Option<**String**> |  | [optional]
**tls_key_store_type** | Option<**String**> |  | [optional]
**tls_provider** | Option<**String**> |  | [optional]
**tls_require_trusted_client_cert_on_connect** | Option<**bool**> |  | [optional]
**tls_trust_certs_file_path** | Option<**String**> |  | [optional]
**tls_trust_chain_bytes** | Option<**Vec<String>**> |  | [optional]
**tls_trust_store** | Option<**String**> |  | [optional]
**tls_trust_store_password** | Option<**String**> |  | [optional]
**tls_trust_store_type** | Option<**String**> |  | [optional]
**topic_compaction_frequency_sec** | Option<**i64**> |  | [optional]
**upload_builtin_sinks_sources** | Option<**bool**> |  | [optional]
**use_compacted_metadata_topic** | Option<**bool**> |  | [optional]
**use_tls** | Option<**bool**> |  | [optional]
**validate_connector_config** | Option<**bool**> |  | [optional]
**web_service_tls_ciphers** | Option<**Vec<String>**> |  | [optional]
**web_service_tls_protocols** | Option<**Vec<String>**> |  | [optional]
**worker_hostname** | Option<**String**> |  | [optional]
**worker_id** | Option<**String**> |  | [optional]
**worker_list_probe_interval_sec** | Option<**i32**> |  | [optional]
**worker_port** | Option<**i32**> |  | [optional]
**worker_port_tls** | Option<**i32**> |  | [optional]
**worker_web_address** | Option<**String**> |  | [optional]
**worker_web_address_tls** | Option<**String**> |  | [optional]
**zoo_keeper_allow_read_only_operations** | Option<**bool**> |  | [optional]
**zoo_keeper_cache_expiry_seconds** | Option<**i32**> |  | [optional]
**zoo_keeper_operation_timeout_seconds** | Option<**i32**> |  | [optional]
**zoo_keeper_session_timeout_millis** | Option<**i64**> |  | [optional]

[[Back to Model list]](../README.md#documentation-for-models) [[Back to API list]](../README.md#documentation-for-api-endpoints) [[Back to README]](../README.md)