| /dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/kafka/tests/ |
| H A D | test_kafka_topic.c | 81 TestSuite(kafka_topic, .init = setup, .fini = teardown);
83 ParameterizedTestParameters(kafka_topic, valid_topic_tests) in ParameterizedTestParameters() argument
101 ParameterizedTest(struct valid_topic_test_params *param, kafka_topic, valid_topic_tests) in ParameterizedTest() argument
108 ParameterizedTestParameters(kafka_topic, invalid_topic_tests) in ParameterizedTestParameters() argument
134 ParameterizedTest(struct invalid_topic_test_params *param, kafka_topic, invalid_topic_tests) in ParameterizedTest() argument
144 Test(kafka_topic, test_resolve_template_topic_name) in Test() argument
174 Test(kafka_topic, test_calculate_topic_from_template) in Test() argument
207 Test(kafka_topic, test_get_literal_topic) in Test() argument
232 Test(kafka_topic, test_calculate_topic) in Test() argument
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/src/tee_plugin/ |
| H A D | tee_recvs.c | 202 int len = sizeof(table->pools[table->num].kafka_topic); in tee_recvs_map_kafka_topic_handler()
204 memset(table->pools[table->num].kafka_topic, 0, len); in tee_recvs_map_kafka_topic_handler()
205 strlcpy(table->pools[table->num].kafka_topic, value, len); in tee_recvs_map_kafka_topic_handler()
206 table->pools[table->num].kafka_topic[len] = '\0'; in tee_recvs_map_kafka_topic_handler()
295 if (!strlen(table->pools[table->num].kafka_topic)) { in tee_recvs_map_validate()
345 … memset(&table->pools[table->num].kafka_topic, 0, sizeof(table->pools[table->num].kafka_topic)); in tee_recvs_map_validate()
|
| H A D | tee_plugin.h | 63 char kafka_topic[SRVBUFLEN]; /* Emitting to Kafka: topic */ member
|
| H A D | tee_plugin.c | 506 Tee_init_kafka_host(kafka_host, pool->kafka_broker, pool->kafka_topic, pool->id); in Tee_kafka_send()
587 … memset(receivers.pools[pool_idx].kafka_topic, 0, sizeof(receivers.pools[pool_idx].kafka_topic)); in Tee_destroy_recvs()
640 receivers.pools[pool_idx].kafka_topic, receivers.pools[pool_idx].id); in Tee_init_socks()
654 void Tee_init_kafka_host(struct p_kafka_host *kafka_host, char *kafka_broker, char *kafka_topic, u_… in Tee_init_kafka_host() argument
659 p_kafka_set_topic(kafka_host, kafka_topic); in Tee_init_kafka_host()
|
| /dports/net-mgmt/py-napalm-logs/napalm-logs-0.9.0/napalm_logs/transport/ |
| H A D | kafka.py | 40 self.kafka_topic = kwargs.get('topic', 'napalm-logs')
50 self.producer.send(self.kafka_topic, obj)
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/examples/kafka/ |
| H A D | kafka_consumer.py | 70 kafka_topic = None
91 kafka_topic = a
137 consumer.subscribe([kafka_topic])
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/grafana/tests/integration/targets/grafana_notification_channel/tasks/ |
| H A D | kafka.yml | 9 kafka_topic: test
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/examples/ |
| H A D | tee_receivers.lst.example | 30 ! 'kafka_topic' SET: Defines the Kafka topic to emit to. Mandatory
|
| /dports/sysutils/flowgger/flowgger-0.2.10/ |
| H A D | flowgger.toml | 107 # kafka_topic = "test"
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/surface/data_catalog/entries/ |
| H A D | update.yaml | 98 - !REF googlecloudsdk.command_lib.data_catalog.entries.v1_flags:kafka_topic
|
| /dports/sysutils/ansible/ansible-4.7.0/ansible_collections/community/grafana/plugins/modules/ |
| H A D | grafana_notification_channel.py | 712 kafka_topic=dict(type='str'),
|
| /dports/net/google-cloud-sdk/google-cloud-sdk/lib/googlecloudsdk/command_lib/data_catalog/entries/ |
| H A D | v1_flags.yaml | 146 kafka_topic:
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/ |
| H A D | CONFIG-KEYS | 583 The base name for the string is defined by amqp_routing_key or kafka_topic. This key
587 -> blabla_0 and so forth. This works in the same fashion for kafka_topic. By default
589 or Kafka topic (or the default one, if no amqp_routing_key or kafka_topic is being
685 KEY: kafka_topic
687 kafka_topic through the use of variables, which are computed at the moment when data
804 DESC: See kafka_topic. Variables supported by the configuration directives described
1606 "<kafka_topic>-value" (ie. if kafka_topic is set to 'foobar' then the schema name will be
1676 for dynamic naming of the topic. See kafka_topic for more info.
2339 … "<kafka_topic>-<bgp/bmp suffix>-value" (ie. if Kafka topic is set to 'foobar' then the
2987 variables are supported for dynamic naming of the topic. See kafka_topic for more
|
| H A D | ChangeLog | 442 kafka_topic knobs are now available in the tee_receivers map and a
705 kafka_topic and amqp_routing_key variables support was harmonized
|
| H A D | QUICKSTART | 1028 kafka_topic: pmacct.acct
|