[jira] [Created] (SPARK-28163) Kafka ignores user configuration on FETCH_OFFSET_NUM_RETRY and FETCH_OFFSET_RETRY_INTERVAL_MS

["Gabor Somogyi (JIRA)" <ji...@apache.org>]

Gabor Somogyi created SPARK-28163:
-------------------------------------

             Summary: Kafka ignores user configuration on FETCH_OFFSET_NUM_RETRY and FETCH_OFFSET_RETRY_INTERVAL_MS
                 Key: SPARK-28163
                 URL: https://issues.apache.org/jira/browse/SPARK-28163
             Project: Spark
          Issue Type: Bug
          Components: Structured Streaming
    Affects Versions: 3.0.0
            Reporter: Gabor Somogyi


There are "unsafe" conversions in the Kafka connector.
CaseInsensitiveStringMap comes in which is then converted the following way:
{code:java}
...
options.asScala.toMap
...
{code}
The main problem with this that such case it looses its case insensitive nature.
Case insensitive map is converting the key to lower case when get/contains called.




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org