список всех запущенных конфигураций на брокере кафки

Question

Я хочу перечислить все конфигурации, активные на брокере kafka.Я мог видеть конфигурации в файлах server.properties, но это еще не все, он не показывает все конфигурации.Я хочу видеть все конфигурации, даже настройки по умолчанию.Это возможно?Любые указатели в этом направлении будут с благодарностью.

Answer 1

Нет команды, которая перечисляет текущую конфигурацию брокера kafka.Однако, если вы хотите увидеть все параметры конфигурации со значениями по умолчанию и важностью, они перечислены здесь

https://docs.confluent.io/current/installation/configuration/broker-configs.html

Answer 2

Вы можете достичь этого программно через Kafka AdminClient (я использую 2.0 FWIW - интерфейс все еще развивается):

        final String brokerId = "1";
        final ConfigResource cr = new ConfigResource(Type.BROKER, brokerId);
        final DescribeConfigsResult dcr = admin.describeConfigs(Arrays.asList(cr));
        final Map<ConfigResource, Config> configMap = dcr.all().get();
        for (final Config config : configMap.values()) {
            for (final ConfigEntry entry : config.entries()) {
                System.out.println(entry);
            }
        }

KafkaAdmin Javadoc

Каждыйзаписей конфигурации имеет свойство source , которое указывает, откуда оно берется (в случае брокера это конфигурация брокера по умолчанию или переопределение для каждого брокера; для тем больше возможных значений).