Skip to content
This repository has been archived by the owner on Jun 29, 2023. It is now read-only.

enabled URI parse/check of multiple kafka bootstrap hosts #265

Merged
merged 3 commits into from Jan 21, 2022

Conversation

cumafo
Copy link
Contributor

@cumafo cumafo commented Feb 24, 2021

Make sure that:

  • You have read the contribution guidelines.
  • You use the code formatters provided here and have them applied to your changes. Don’t submit any formatting related changes.
  • You submit test cases (unit or integration tests) that back your changes.

@cumafo cumafo changed the title enabled URI parse/check of multiple bootstrap hosts enabled URI parse/check of multiple kafka bootstrap hosts Mar 1, 2021
@mp911de mp911de added the type: enhancement A general enhancement label Mar 1, 2021
@mp911de mp911de added this to the 1.15.0 milestone Mar 1, 2021
port = BROKER_DEFAULT_PORT;
// extract the host part from uri and put in an array
// so each host can be validated using the URI
String kafkaPrefix = KafkaContants.KAFKA_SCHEME + "://";
Copy link
Owner

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The scheme-specific part can be extracted directly from an URI.

@mp911de mp911de merged commit 6ff4e5c into mp911de:main Jan 21, 2022
mp911de added a commit that referenced this pull request Jan 21, 2022
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
type: enhancement A general enhancement
Projects
None yet
Development

Successfully merging this pull request may close these issues.

log4j2 kafka appender unable to handle multiple bootstrap hosts, i.e kafka://host1:9092,host2:9092#topic
2 participants