Changed describe configs

Author: PratRanj07

examples/adminapi.py

@@ -103,12 +103,13 @@ def example_create_partitions(a, topics):
 
 
 def print_config(config, depth):
-    print('%40s = %-50s  [%s,is:read-only=%r,default=%r,sensitive=%r,synonym=%r,synonyms=%s]' %
+    print('%40s = %-50s  [%s,is:read-only=%r,default=%r,sensitive=%r,synonym=%r,synonyms=%s,type=%r, documentation=%s]' %
           ((' ' * depth) + config.name, config.value, ConfigSource(config.source),
            config.is_read_only, config.is_default,
            config.is_sensitive, config.is_synonym,
            ["%s:%s" % (x.name, ConfigSource(x.source))
-            for x in iter(config.synonyms.values())]))
+            for x in iter(config.synonyms.values())],
+           config.type, config.documentation))
 
 
 def example_describe_configs(a, args):

src/confluent_kafka/admin/_config.py

@@ -58,6 +58,25 @@ class ConfigSource(Enum):
     DEFAULT_CONFIG = _cimpl.CONFIG_SOURCE_DEFAULT_CONFIG  #: Default
 
 
+class ConfigType(Enum):
+    """
+    Enumerates the different types of configuration properties.
+    Used by ConfigEntry to specify the
+    type of configuration properties returned by `describe_configs()`.
+    """
+    UNKNOWN = _cimpl.CONFIG_TYPE_UNKNOWN  #: Unknown
+    BOOLEAN = _cimpl.CONFIG_TYPE_BOOLEAN  #: Boolean
+    STRING = _cimpl.CONFIG_TYPE_STRING  #: String
+    INT = _cimpl.CONFIG_TYPE_INT  #: Integer
+    SHORT = _cimpl.CONFIG_TYPE_SHORT  #: Short
+    LONG = _cimpl.CONFIG_TYPE_LONG  #: Long
+    DOUBLE = _cimpl.CONFIG_TYPE_DOUBLE  #: Double
+    LIST = _cimpl.CONFIG_TYPE_LIST  #: List
+    CLASS = _cimpl.CONFIG_TYPE_CLASS  #: Class
+    PASSWORD = _cimpl.CONFIG_TYPE_PASSWORD  #: Password
+    CNT = _cimpl.CONFIG_TYPE_CNT  #: Count
+
+
 class ConfigEntry(object):
     """
     Represents a configuration property. Returned by describe_configs() for each configuration
@@ -72,6 +91,8 @@ def __init__(self, name, value,
                  is_default=False,
                  is_sensitive=False,
                  is_synonym=False,
+                 type=ConfigType.UNKNOWN,
+                 documentation=None,
                  synonyms=[],
                  incremental_operation=None):
         """
@@ -100,6 +121,10 @@ def __init__(self, name, value,
         """Indicates whether the configuration property is a synonym for the parent configuration entry."""
         self.synonyms = synonyms
         """A list of synonyms (ConfigEntry) and alternate sources for this configuration property."""
+        self.type = type
+        """The type of the configuration property."""
+        self.documentation = documentation
+        """The documentation for the configuration property."""
         self.incremental_operation = incremental_operation
         """The incremental operation (AlterConfigOpType) to use in incremental_alter_configs."""
 

src/confluent_kafka/src/Admin.c

@@ -3435,6 +3435,7 @@ Admin_c_ConfigEntries_to_py (PyObject *ConfigEntry_type,
                 PyObject *kwargs, *args;
                 const rd_kafka_ConfigEntry_t *ent = c_configs[ci];
                 const rd_kafka_ConfigEntry_t **c_synonyms;
+                const char *documentation;
                 PyObject *entry, *synonyms;
                 size_t synonym_cnt;
                 const char *val;
@@ -3472,6 +3473,13 @@ Admin_c_ConfigEntries_to_py (PyObject *ConfigEntry_type,
                 PyDict_SetItemString(kwargs, "synonyms", synonyms);
                 Py_DECREF(synonyms);
 
+                cfl_PyDict_SetInt(kwargs, "type", rd_kafka_ConfigEntry_type(ent));
+
+                documentation = rd_kafka_ConfigEntry_documentation(ent);
+
+                if (documentation)
+                        cfl_PyDict_SetString(kwargs, "documentation", documentation);
+
                 args = PyTuple_New(0);
                 entry = PyObject_Call(ConfigEntry_type, args, kwargs);
                 Py_DECREF(args);

src/confluent_kafka/src/AdminTypes.c

@@ -516,6 +516,21 @@ static void AdminTypes_AddObjectsConfigSource (PyObject *m) {
                                 RD_KAFKA_CONFIG_SOURCE_DEFAULT_CONFIG);
 }
 
+static void AdminTypes_AddObjectsConfigType(PyObject *m) {
+    /* rd_kafka_ConfigType_t */
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_UNKNOWN", RD_KAFKA_CONFIG_UNKNOWN);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_BOOLEAN", RD_KAFKA_CONFIG_BOOLEAN);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_STRING", RD_KAFKA_CONFIG_STRING);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_INT", RD_KAFKA_CONFIG_INT);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_SHORT", RD_KAFKA_CONFIG_SHORT);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_LONG", RD_KAFKA_CONFIG_LONG);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_DOUBLE", RD_KAFKA_CONFIG_DOUBLE);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_LIST", RD_KAFKA_CONFIG_LIST);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_CLASS", RD_KAFKA_CONFIG_CLASS);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_PASSWORD", RD_KAFKA_CONFIG_PASSWORD);
+    PyModule_AddIntConstant(m, "CONFIG_TYPE_CNT", RD_KAFKA_CONFIG__CNT);
+}
+
 
 static void AdminTypes_AddObjectsResourceType (PyObject *m) {
         /* rd_kafka_ResourceType_t */
@@ -622,6 +637,7 @@ void AdminTypes_AddObjects (PyObject *m) {
         PyModule_AddObject(m, "NewPartitions", (PyObject *)&NewPartitionsType);
 
         AdminTypes_AddObjectsConfigSource(m);
+        AdminTypes_AddObjectsConfigType(m);
         AdminTypes_AddObjectsResourceType(m);
         AdminTypes_AddObjectsResourcePatternType(m);
         AdminTypes_AddObjectsAclOperation(m);