{"name":"io.github.arogan178/nifi-clickhouse-kafka-mcp","slug":"arogan178-nifi-clickhouse-kafka-mcp","title":"nifi-clickhouse-kafka-mcp","description":"Read-only Apache NiFi, ClickHouse and Kafka access with OIDC, audit and secret masking","url":"https://mcp.market/server/arogan178-nifi-clickhouse-kafka-mcp","rating":null,"grade":"A","score":92,"certified":false,"status":"active","category":"data","tags":["data","security"],"presence":{"score":24,"stars":0,"forks":0,"downloads_week":66,"last_push_at":"2026-10-19T13:07:34.000Z","license":"Apache-2.0"},"uptime":null,"claimed":false,"transport":"pypi","callable_via_gateway":false,"default_price_micros":0,"repository":"https://github.com/arogan178/nifi-clickhouse-kafka-mcp","website":null,"version":"0.1.0","remotes":[],"packages":[{"registryType":"pypi","identifier":"nifi-clickhouse-kafka-mcp","version":"0.1.0","runtimeHint":"uvx","transport":{"type":"stdio"},"environmentVariables":[{"description":"Path to the config file; see examples/config.example.yaml in the repository","isRequired":true,"format":"filepath","name":"NIFI_CLICKHOUSE_KAFKA_MCP_CONFIG"}]}],"tools":[{"name":"clickhouse_databases","description":"Databases with their engine, table count and total size.","write_action":false,"price_micros":0,"input_schema":null},{"name":"clickhouse_describe_table","description":"Columns (name, type, default, comment) plus engine, sorting, primary and partition keys and size of a table.","write_action":false,"price_micros":0,"input_schema":null},{"name":"clickhouse_health","description":"Server health in one call: version and uptime, replicas with problems, disk use, partitions with the most active parts, longest running queries, merges, unfinished mutations and errors in the last hour.","write_action":false,"price_micros":0,"input_schema":null},{"name":"clickhouse_query","description":"Run one read-only ClickHouse statement (SELECT, WITH, SHOW, DESCRIBE, EXISTS, EXPLAIN).","write_action":true,"price_micros":0,"input_schema":null},{"name":"clickhouse_search_columns","description":"Find columns whose name or comment contains a string (case-insensitive), across all user tables.","write_action":false,"price_micros":0,"input_schema":null},{"name":"clickhouse_tables","description":"Tables and views with engine, rows, size and comment, sorted by database and name.","write_action":false,"price_micros":0,"input_schema":null},{"name":"environments","description":"The environments this server can read, with their description and which systems each one has.","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_cluster","description":"Brokers, controller, topic and partition counts, and under-replicated or offline partitions.","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_consumer_groups","description":"List consumer groups (id and state) sorted by id, optionally filtered by a substring.","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_consumer_lag","description":"Committed offsets and lag per partition for an existing consumer group (see kafka_consumer_groups).","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_describe_topic","description":"Partitions with earliest/latest offsets and non-default configs of a Kafka topic.","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_sample","description":"Read up to 50 messages from one partition without joining any consumer group.","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_search","description":"Scan all partitions of a topic for messages matching every given filter, without joining a group.","write_action":false,"price_micros":0,"input_schema":null},{"name":"kafka_topics","description":"List Kafka topics sorted by name, optionally filtered by a substring.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_bulletins","description":"Recent NiFi bulletins (warnings and errors), optionally for one component.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_component","description":"Full configuration of one NiFi component, without property descriptors.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_controller_services","description":"Controller services of a process group and its ancestors, with their state.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_flow_tree","description":"Process group hierarchy with ids, queued data and processor counts by state, down to depth levels.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_flowfile","description":"Attributes of one queued FlowFile (see nifi_queue), optionally with content[offset:offset+length].","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_health","description":"Problems in a flow in one call, worst first.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_parameter","description":"One NiFi parameter's value, value[offset:offset+length]; next_offset is None at the end.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_parameters","description":"Parameters of all readable NiFi parameter contexts, sorted by context and name.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_process_group","description":"Contents of a process group: child groups, processors, connections with queue sizes, ports.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_processor_state","description":"Stored state of a processor, e.g. the last listed timestamp or maximum column values.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_provenance","description":"Search NiFi provenance events of a component (processor, port, ...) and/or a FlowFile.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_provenance_event","description":"One provenance event (see nifi_provenance) with attributes, previous values that changed, and content.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_queue","description":"FlowFiles at the head of a connection's queue (NiFi lists at most 100), with total queue size.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_search","description":"Search the NiFi flow for components by name, id, property or type.","write_action":false,"price_micros":0,"input_schema":null},{"name":"nifi_status","description":"NiFi version, controller status (threads, queued data, component counts) and cluster node summary.","write_action":false,"price_micros":0,"input_schema":null}],"scan":{"score":92,"grade":"A","scanned_at":"2026-10-27T18:16:48.656Z","report":{"scannerVersion":"0.1.10","scannedAt":"2026-10-27T18:16:48.612Z","components":{"code":{"score":25,"max":25,"notes":["17 source files scanned"]},"reliability":{"score":-1,"max":20,"notes":["no gateway calls yet and no remote to probe"]},"poisoning":{"score":-1,"max":15,"notes":["tools not inspected (local package is not executed); not counted"]},"auth":{"score":12,"max":15,"notes":["local package, no credentials required"]},"maintenance":{"score":15,"max":15,"notes":["last push 8 days ago"]},"identity":{"score":8,"max":10,"notes":["registry namespace matches repository owner","GitHub account older than a year"]}},"findings":[],"inputs":{"packages":[{"registryType":"pypi","identifier":"nifi-clickhouse-kafka-mcp","version":"0.1.0","found":true,"weeklyDownloads":66,"license":"Apache-2.0","dependencyCount":11,"publishedAt":"2026-10-19T13:08:32.579982Z","repositoryUrl":"https://github.com/arogan178/nifi-clickhouse-kafka-mcp"}],"repo":{"found":true,"owner":"arogan178","repo":"nifi-clickhouse-kafka-mcp","archived":false,"pushedAt":"2026-10-19T13:07:34Z","stars":0,"forks":0,"openIssues":0,"ownerType":"User","ownerAvatarUrl":"https://avatars.githubusercontent.com/u/25248102?v=4","ownerCreatedAt":"2017-01-20T14:06:29Z","license":"Apache-2.0"},"icon":{"url":"https://avatars.githubusercontent.com/u/25248102?v=4&s=128","source":"github"},"presence":{"stars":0,"forks":0,"downloadsWeek":66,"license":"Apache-2.0","lastPushAt":"2026-10-19T13:07:34.000Z","score":24}}}},"grade_history":[],"reviews":[]}