bowenli-oai commented on PR #203:
URL:
https://github.com/apache/flink-connector-kafka/pull/203#issuecomment-3672776841
```
.tox/py311-cython/lib/python3.11/site-packages/pyflink/datastream/connectors/__init__.py:44:
in _install
setattr(connectors, 'FlinkKafkaConsumer', kafka.FlinkKafkaConsumer)
^^^^^^^^^^^^^^^^^^^^^^^^
E AttributeError: module 'pyflink.datastream.connectors.kafka' has no
attribute 'FlinkKafkaConsumer'
```
got error from CI. However, `FlinkKafkaConsumer` does not exist in kafka.py
in this repo but only exist in flink's core repo
looks like the CI in this connector repo is still polling kafka.py from
flink's core repo instead of the one in this repo? looks like
https://github.com/apache/flink-connector-kafka/pull/69 is not complete, and
didn't actually publish any python package?
Cc @dianfu do you have any insights?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
