Skip to content

Optimized code for kafka component#3730

Merged
limingxinleo merged 1 commit intohyperf:2.2from
limingxinleo:2.2-kafka
Jun 23, 2021
Merged

Optimized code for kafka component#3730
limingxinleo merged 1 commit intohyperf:2.2from
limingxinleo:2.2-kafka

Conversation

@limingxinleo
Copy link
Copy Markdown
Member

@limingxinleo limingxinleo commented Jun 23, 2021

  • Support timeout for Producer to avoid requests not responding.
  • Removed useless code with pool.
  • Throw exceptions when connect kafka failed.
  • Removed config brokers and update_brokers from kafka.

@limingxinleo
Copy link
Copy Markdown
Member Author

@PandaLIU-1111 看一下

@limingxinleo limingxinleo merged commit da60424 into hyperf:2.2 Jun 23, 2021
@limingxinleo limingxinleo deleted the 2.2-kafka branch June 23, 2021 12:25
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant