You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@atlas.apache.org by "Vimal Sharma (JIRA)" <ji...@apache.org> on 2016/08/22 13:21:20 UTC
[jira] [Updated] (ATLAS-1131) Atlas hooks produce excess Kafka logs
if Kafka topic is not created already
[ https://issues.apache.org/jira/browse/ATLAS-1131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Vimal Sharma updated ATLAS-1131:
--------------------------------
Attachment: ATLAS-1131.patch
> Atlas hooks produce excess Kafka logs if Kafka topic is not created already
> ---------------------------------------------------------------------------
>
> Key: ATLAS-1131
> URL: https://issues.apache.org/jira/browse/ATLAS-1131
> Project: Atlas
> Issue Type: Bug
> Reporter: Vimal Sharma
> Assignee: Vimal Sharma
> Attachments: ATLAS-1131.patch
>
>
> Hooks for Atlas publish messages to a Kafka topic named ATLAS_HOOK. If this topic is not present and Atlas does not have permission to create this topic, Kafka produces excessive logs as below (example in /tmp/hive/hive.log).
> 2016-08-22 06:43:47,655 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1177 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:47,756 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1178 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:47,858 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1179 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:47,961 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1180 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:48,062 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1181 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:48,165 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1182 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:48,265 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1183 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:48,366 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1184 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
> 2016-08-22 06:43:48,467 WARN [kafka-producer-network-thread | producer-1]: clients.NetworkClient (NetworkClient.java:handleResponse(600)) - Error while fetching metadata with correlation id 1185 : {ATLAS_HOOK=UNKNOWN_TOPIC_OR_PARTITION}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)