Page History
...
| Code Block |
|---|
create_topic.sh basepath="localhost:8086/administration" topic="http://www.dkma.dk/medicinecard/xml.schema/2012/06/01:MedicineCard" internal_topicinternalTopic="dk.nsp.bo.nas.fmk.MedicineCard" num_partitionsnumPartitions=6 replication_factorreplicationFactor=2 |
Udover de ovenstående parametre er det desuden også muligt at sætte følgendekafka topic config parametre, hvis ønsket :
segment_bytes
segment_ms
segment_jitter_ms
segment_indexbytes
flush_messages_interval
flush_ms
retention_bytes
retention_ms
max_message_bytes
index_interval_bytes
file_delete_delay_ms
delete_retention_ms
min_compaction_lag_ms
min_cleanable_dirty_ratio
cleanup_policy
unclean_leader_election_enable
min_in_sync_replicas
compression_type
preallocate
message_format_version
message_timestamp_type
message_timestamp_difference_max_ms(fx cleanup.policy=delete).
Mulige kafka topic config parametre findes fx her: https://kafka.apache.org/documentation/#topicconfigs
Opret Topic Access
Efter oprettelse af et Topic, tildeles adgang ved at oprette Topic access.
...