[
https://issues.apache.org/jira/browse/FLINK-7174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16092616#comment-16092616
]
ASF GitHub Bot commented on FLINK-7174:
---------------------------------------
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4321
@pnowojski we can't just drop that test, IMO. It's crucial that those tests
exist to guard against incorrect reassignment logic in the
`KafkaConsumerThread`. Breaking that would mess up the shutdown responsiveness
of the consumer thread.
I'm not sure why your current fix would be bad, though. Or why do you want
it to be removed?
> Bump dependency of Kafka 0.10.x to the latest one
> -------------------------------------------------
>
> Key: FLINK-7174
> URL: https://issues.apache.org/jira/browse/FLINK-7174
> Project: Flink
> Issue Type: Improvement
> Components: Kafka Connector
> Reporter: Piotr Nowojski
> Assignee: Piotr Nowojski
>
> We are using pretty old Kafka version for 0.10. Besides any bug fixes and
> improvements that were made between 0.10.0.1 and 0.10.2.1, it 0.10.2.1
> version is more similar to 0.11.0.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
