Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id C1AD2200D60 for ; Fri, 1 Dec 2017 14:50:55 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id C0676160C06; Fri, 1 Dec 2017 13:50:55 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 38449160BFB for ; Fri, 1 Dec 2017 14:50:55 +0100 (CET) Received: (qmail 34926 invoked by uid 500); 1 Dec 2017 13:50:54 -0000 Mailing-List: contact dev-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list dev@kafka.apache.org Received: (qmail 34915 invoked by uid 99); 1 Dec 2017 13:50:53 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Dec 2017 13:50:53 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 59598E01C4; Fri, 1 Dec 2017 13:50:51 +0000 (UTC) From: ethiebaut To: dev@kafka.apache.org Reply-To: dev@kafka.apache.org Message-ID: Subject: [GitHub] kafka pull request #4282: KAFKA-6293 Support for Avro formatter in ConsoleCo... Content-Type: text/plain Date: Fri, 1 Dec 2017 13:50:51 +0000 (UTC) archived-at: Fri, 01 Dec 2017 13:50:55 -0000 GitHub user ethiebaut opened a pull request: https://github.com/apache/kafka/pull/4282 KAFKA-6293 Support for Avro formatter in ConsoleConsumer Support for Avro formatter in ConsoleConsumer With Confluent Schema Registry as per https://issues.apache.org/jira/browse/KAFKA-6293 This adds the ability the display Avro payloads when listening for messages in kafka-console-consumer.sh. This proposed PR will display Avro payloads (in JSON) when executed with the following parameters: bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytopic --confluent-server localhost:8081 --formatter kafka.tools.AvroMessageFormatter This contribution is my original work and I license the work to the project under the project's open source license. All tests passed: BUILD SUCCESSFUL in 21m 18s 90 actionable tasks: 60 executed, 30 up-to-date You can merge this pull request into a Git repository by running: $ git pull https://github.com/ethiebaut/kafka avro-deserializer Alternatively you can review and apply these changes as the patch at: https://github.com/apache/kafka/pull/4282.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4282 ---- commit a49102979ddd0183070e8aef2cf1cafb9ee317cd Author: Eric Thiebaut-George Date: 2017-12-01T12:54:39Z KAFKA-6293 Support for Avro formatter in ConsoleConsumer With Confluent Schema Registry ---- ---