fix some suggestions by copilot

Author: fangnx

src/confluent_kafka/admin/__init__.py

@@ -1000,7 +1000,7 @@ def describe_consumer_groups(  # type: ignore[override]
         f, futmap = AdminClient._make_futures(group_ids, None,
                                               AdminClient._make_consumer_groups_result)
 
-        super(AdminClient, self).describe_consumer_groups(group_ids, f, **kwargs)  # type: ignore[arg-type]
+        super(AdminClient, self).describe_consumer_groups(group_ids, f, **kwargs)
 
         return futmap
 

src/confluent_kafka/admin/_listoffsets.py

@@ -159,4 +159,6 @@ class ListOffsetsResultInfo:
     def __init__(self, offset: int, timestamp: int, leader_epoch: int) -> None:
         self.offset = offset
         self.timestamp = timestamp
-        self.leader_epoch: Optional[int] = leader_epoch if leader_epoch >= 0 else None
+        self.leader_epoch: Optional[int] = leader_epoch
+        if leader_epoch < 0:
+            self.leader_epoch = None

src/confluent_kafka/cimpl.pyi

@@ -85,8 +85,8 @@ class Message:
     def latency(self) -> Optional[float]: ...
     def leader_epoch(self) -> Optional[int]: ...
     def set_headers(self, headers: HeadersType) -> None: ...
-    def set_key(self, key: bytes) -> None: ...
-    def set_value(self, value: bytes) -> None: ...
+    def set_key(self, key: Any) -> None: ...
+    def set_value(self, value: Any) -> None: ...
     def __len__(self) -> int: ...
 
 class TopicPartition:
@@ -263,8 +263,8 @@ class _AdminClientImpl:
     ) -> Any: ...
     def describe_consumer_groups(
         self,
-        future: Any,
         group_ids: List[str],
+        future: Any,
         request_timeout: float = -1,
         include_authorized_operations: bool = False
     ) -> None: ...

src/confluent_kafka/deserializing_consumer.py

@@ -123,8 +123,8 @@ def poll(self, timeout: float = -1) -> Optional[Message]:
             except Exception as se:
                 raise KeyDeserializationError(exception=se, kafka_message=msg)
 
-        msg.set_key(key)  # type: ignore[arg-type]
-        msg.set_value(value)  # type: ignore[arg-type]
+        msg.set_key(key)
+        msg.set_value(value)
         return msg
 
     def consume(self, num_messages: int = 1, timeout: float = -1) -> List[Message]:

src/confluent_kafka/experimental/aio/_common.py

@@ -32,7 +32,7 @@ def __init__(
         self.logger = logger
 
     def log(self, *args: Any, **kwargs: Any) -> None:
-        self.loop.call_soon_threadsafe(lambda: self.logger.log(*args, **kwargs))
+        self.loop.call_soon_threadsafe(self.logger.log, *args, **kwargs)
 
 
 def wrap_callback(