Skip to content

warn if topic not found#4834

Merged
jihoonson merged 1 commit intoapache:masterfrom
pjain1:kafka_log
Sep 25, 2017
Merged

warn if topic not found#4834
jihoonson merged 1 commit intoapache:masterfrom
pjain1:kafka_log

Conversation

@pjain1
Copy link
Copy Markdown
Member

@pjain1 pjain1 commented Sep 21, 2017

No description provided.

@himanshug
Copy link
Copy Markdown
Contributor

👍

@pjain1 pjain1 modified the milestones: 0.11.1, 0.11.0 Sep 21, 2017
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

How about moving this logging to after https://github.com/druid-io/druid/pull/4834/files#diff-6eee87b3aa4eb3a516965fe6e93e25a4R778? The check on topics.containsKey() can be changed to null check on partitions.

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

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

changed...however I am curious why it is better than this ?

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Thanks. It's very trivial, but I think it's better to read because the existence check on topic is done in one place.

@pjain1 pjain1 closed this Sep 25, 2017
@pjain1 pjain1 reopened this Sep 25, 2017
@pjain1 pjain1 closed this Sep 25, 2017
@pjain1 pjain1 reopened this Sep 25, 2017
@jihoonson jihoonson merged commit 07446ef into apache:master Sep 25, 2017
@pjain1 pjain1 deleted the kafka_log branch September 25, 2017 03:26
gianm pushed a commit to gianm/druid that referenced this pull request Sep 26, 2017
jon-wei pushed a commit that referenced this pull request Sep 26, 2017
seoeun25 added a commit to seoeun25/incubator-druid that referenced this pull request Jan 10, 2020
* Refactoring Appendertor Driver (apache#4292)

* Rename FiniteAppenderatorDriver to AppenderatorDriver (apache#4356)

* Add totalRowCount to appenderator

* add localhost as advertised hostname (apache#4689)

* kafkaIndexTask unannounce service in final block (apache#4736)

* warn if topic not found (apache#4834)

* Kafka: Fixes needlessly low interpretation of maxRowsInMemory. (apache#5034)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants