`; // Utility functions const DESCRIPTION_LIMIT = 130; const LIMIT_NUMBER = '9223372036854775807'; function formatNumber(value) { if (typeof value !== 'string' && typeof value !== 'number') { return value; } const parsedNumber = Number(value); if (Number.isNaN(parsedNumber) || value === '') { return value; } return parsedNumber.toLocaleString('fr-FR'); } function formatBytes(value) { const bytes = Number(value); if (Number.isNaN(bytes)) { return String(value); } if (bytes === 0) { return '0 B'; } const marker = 1024; const decimals = 2; const sizes = ['B', 'KB', 'MB', 'GB', 'TB', 'PB']; const sizeIndex = Math.floor(Math.log(Math.abs(bytes)) / Math.log(marker)); const maxSizeIndex = Math.min(sizeIndex, sizes.length - 1); const formattedBytes = parseFloat((bytes / Math.pow(marker, maxSizeIndex)).toFixed(decimals)); return `${formatNumber(formattedBytes)} ${sizes[maxSizeIndex]}`; } function formatMs(value) { const ms = Number(value); if (ms === 0 || isNaN(ms)) { return '0ms'; } const seconds = ms / 1000; const minutes = seconds / 60; const hours = minutes / 60; const days = hours / 24; const months = days / 30; const years = days / 365; const data = [ { key: () => 'y', value: years, msMultiply: 365 * 24 * 60 * 60 * 1000 }, { key: (value) => (value === 1 ? 'mth' : 'mths'), value: months, msMultiply: 30 * 24 * 60 * 60 * 1000 }, { key: () => 'd', value: days, msMultiply: 24 * 60 * 60 * 1000 }, { key: () => 'h', value: hours, msMultiply: 60 * 60 * 1000 }, { key: () => 'min', value: minutes, msMultiply: 60 * 1000 }, { key: () => 's', value: seconds, msMultiply: 1000 }, { key: () => 'ms', value: ms, msMultiply: 1 } ]; const limitedDataIndex = data.findIndex(({ value }) => value >= 1); const limitedData = data.slice(limitedDataIndex); const { time } = limitedData.reduce( ({ time, leftMs }, { key, msMultiply }) => { if (leftMs === 0) { return { time, leftMs: 0 }; } const parsedValue = Math.floor(leftMs / msMultiply); return { time: parsedValue === 0 ? time : `${time} ${parsedValue}${key(parsedValue)}`.trim(), leftMs: leftMs - parsedValue * msMultiply }; }, { time: '', leftMs: ms } ); return time; } function formatField(key, value) { const format = key.split('.').pop(); if (!Number.isNaN(Number(value)) && value >= LIMIT_NUMBER) { return String(Number.POSITIVE_INFINITY); } switch (format) { case 'ms': return formatMs(value); case 'bytes': return formatBytes(value); } return value; } function getValueDifference(value, lastValue) { if (!lastValue && value) return 'added'; if (lastValue && !value) return 'removed'; return lastValue !== value ? 'changed' : false; } function unionBy(arr1, arr2, key) { const map = new Map(); [...arr1, ...arr2].forEach(item => { if (!map.has(item[key])) { map.set(item[key], item); } }); return Array.from(map.values()); } // Application state let kafkaOptions = null; let fullDescriptions = []; let toggledTechnologies = []; let searchValue = ''; let minVersion = '3.0'; // Version comparison helper function compareVersions(v1, v2) { const parts1 = v1.split('.').map(p => parseInt(p) || 0); const parts2 = v2.split('.').map(p => parseInt(p) || 0); for (let i = 0; i < Math.max(parts1.length, parts2.length); i++) { const p1 = parts1[i] || 0; const p2 = parts2[i] || 0; if (p1 > p2) return 1; if (p1 < p2) return -1; } return 0; } function getAllVersions() { const versions = new Set(); Object.keys(kafkaOptions).forEach(key => { if (key === 'documentation') return; const items = kafkaOptions[key]; if (Array.isArray(items)) { items.forEach(item => { if (item.version) { versions.add(item.version); } }); } }); return Array.from(versions).sort((a, b) => compareVersions(a, b)); } function populateVersionSelect() { const select = document.getElementById('minVersionSelect'); const versions = getAllVersions(); select.innerHTML = ''; versions.forEach(version => { const option = document.createElement('option'); option.value = version; option.textContent = version; if (version === minVersion) { option.selected = true; } select.appendChild(option); }); } // Initialize async function init() { try { kafkaOptions = window.kafkaOptionsData; // Get search from URL const urlParams = new URLSearchParams(window.location.search); const searchQuery = urlParams.get('search'); if (searchQuery) { searchValue = searchQuery; document.getElementById('searchInput').value = searchQuery; } populateVersionSelect(); renderNavMenu(); renderTables(); setupEventListeners(); } catch (error) { console.error('Error loading kafka options:', error); document.getElementById('tablesContainer').innerHTML = '

Error loading Kafka options data.

'; } } function getDisplayName(key) { const displayNames = { 'connect_default': 'Connect Worker', 'connect_source': 'Connect Source', 'connect_sink': 'Connect Sink', 'stream': 'Kafka Streams' }; return displayNames[key] || key.replace(/_/g, ' '); } function renderNavMenu() { const navCategories = document.getElementById('navCategories'); const keys = Object.keys(kafkaOptions).filter(key => key !== 'documentation'); let html = ''; keys.forEach((key, index) => { const displayName = getDisplayName(key); html += ` ${displayName} `; }); navCategories.innerHTML = html; } function setupEventListeners() { const searchInput = document.getElementById('searchInput'); const versionSelect = document.getElementById('minVersionSelect'); let debounceTimer; searchInput.addEventListener('input', (e) => { searchValue = e.target.value; // Clear previous timer clearTimeout(debounceTimer); // Update URL and re-render after 300ms of no typing debounceTimer = setTimeout(() => { try { const url = new URL(window.location); url.searchParams.set('search', searchValue); window.history.pushState({}, '', url); } catch (e) { // Ignore history errors in case Next.js router interferes } renderTables(); }, 300); }); versionSelect.addEventListener('change', (e) => { minVersion = e.target.value; renderTables(); }); // Set up intersection observer to highlight active section const observerOptions = { root: null, rootMargin: '-50% 0px -50% 0px', threshold: 0 }; const observer = new IntersectionObserver((entries) => { entries.forEach(entry => { if (entry.isIntersecting) { const index = entry.target.getAttribute('data-index'); document.querySelectorAll('.nav-item').forEach(item => { item.classList.remove('active'); }); const navItem = document.querySelector(`[data-nav-index="${index}"]`); if (navItem) { navItem.classList.add('active'); } } }); }, observerOptions); // Observe all tables document.querySelectorAll('table[data-index]').forEach(table => { observer.observe(table); }); } window.scrollToTechnology = function(index) { const element = document.querySelector(`table[data-index="${index}"]`); if (!element) { console.log('Element not found for index:', index); return; } // Scroll to element with offset for Mintlify navbar const navBarHeight = 100; const elementPosition = element.getBoundingClientRect().top + window.pageYOffset; const offsetPosition = elementPosition - navBarHeight; window.scrollTo({ top: offsetPosition, behavior: 'smooth' }); // Update active nav item document.querySelectorAll('.nav-item').forEach(item => { item.classList.remove('active'); }); const navItem = document.querySelector(`[data-nav-index="${index}"]`); if (navItem) { navItem.classList.add('active'); } } window.toggleDescription = function(configName) { const index = fullDescriptions.indexOf(configName); if (index > -1) { fullDescriptions.splice(index, 1); } else { fullDescriptions.push(configName); } renderTables(); } window.toggleTechnology = function(index) { const toggleIndex = toggledTechnologies.indexOf(index); if (toggleIndex > -1) { toggledTechnologies.splice(toggleIndex, 1); } else { toggledTechnologies.push(index); } renderTables(); } window.copyToClipboard = function(text) { navigator.clipboard.writeText(text).then(() => { // Optional: show a toast notification }); } function renderTables() { const container = document.getElementById('tablesContainer'); const keys = Object.keys(kafkaOptions); const kafkaOptionsValues = Object.values(kafkaOptions); let html = ''; kafkaOptionsValues.forEach((items, index) => { const parent = keys[index]; if (parent === 'documentation') return; // Skip documentation key let data = Array.isArray(items) ? items : []; // Filter versions based on minVersion if (minVersion !== '0.0') { data = data.filter(item => { return item.version && compareVersions(item.version, minVersion) >= 0; }); } // Skip if no versions match the filter if (data.length === 0) return; let configs = []; if (Array.isArray(data)) { data.forEach(item => { configs = unionBy(item.configs || [], configs, 'name'); }); } const filteredConfigs = searchValue && searchValue.length ? configs.filter(config => { const description = kafkaOptions.documentation[config.name] || ''; return config.name.includes(searchValue) || description.includes(searchValue); }) : configs; if (filteredConfigs.length === 0) return; const isCollapsed = toggledTechnologies.includes(index); html += ` ${data.map(item => ``).join('')} `; filteredConfigs.forEach(config => { const description = kafkaOptions.documentation[config.name] || ''; const isExpanded = fullDescriptions.includes(config.name); const isExpandable = description.length > DESCRIPTION_LIMIT; html += ``; data.forEach((item, i) => { const _lastValue = i > 0 ? data[i - 1].configs?.filter(node => node.name === config.name)[0]?.value : null; const _value = item.configs?.filter(node => node.name === config.name)[0]?.value; const lastRawValue = _lastValue?.replace(/ *$[^)]*$ */g, ''); const rawValue = _value?.replace(/ *$[^)]*$ */g, ''); const humanValue = formatField(config.name, rawValue); const different = i > 0 ? getValueDifference(rawValue, lastRawValue) : false; html += ``; }); html += ``; }); html += `

${getDisplayName(parent)}	Description	${item.version}
${config.name}	${isExpanded ? description : description.substr(0, DESCRIPTION_LIMIT)}${isExpandable && !isExpanded ? '..' : ''}	${rawValue \|\| ''} ${rawValue && parseInt(rawValue) > 0 && humanValue !== rawValue ? ` ${humanValue}` : ''}

`; }); container.innerHTML = html; } // Start the app when DOM is ready if (document.readyState === 'loading') { document.addEventListener('DOMContentLoaded', init); } else { init(); } } // Start checking for DOM elements if (typeof window !== 'undefined') { if (document.readyState === 'loading') { document.addEventListener('DOMContentLoaded', initKafkaExplorer); } else { initKafkaExplorer(); } } })();

Get started with Conduktor

Concepts