Registry / messaging / akka-stream-kafka-2-12

akka-stream-kafka-2-12

library4.0.2javamavenunverified

Reactive Enterprise Integration library for Java and Scala, providing Akka Stream connectors for Apache Kafka.

<dependency>
  <groupId>com.typesafe.akka</groupId>
  <artifactId>akka-stream-kafka_2.12</artifactId>
  <version>4.0.2</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · AKKA-STREAM-KAFKA-

akka-stream-kafka-2-12

messagingjavav4.0.2

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

ConsumerSettings

✓ akka.kafka.ConsumerSettings

Create Kafka consumer settings using Alpakka Kafka.

import akka.kafka.ConsumerSettings; import org.apache.kafka.common.serialization.StringDeserializer; public class Example { public static void main(String[] args) { ConsumerSettings<String, String> settings = ConsumerSettings .create(null, new StringDeserializer(), new StringDeserializer()) .withBootstrapServers("localhost:9092") .withGroupId("group1"); System.out.println(settings); } }

Debug

Known issues

breakingThis artifact is for Scala 2.12; ensure your project uses the correct Scala version.

fix

Use the artifact matching your Scala version (e.g., akka-stream-kafka_2.13 for Scala 2.13).

affects: *

Upgrade

Version history

4.0.2latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

31 hits · last 30 days

node

OpenAI (training)

Resources

githubhttps://github.com/akka/alpakka-kafka ↗

homepagehttps://doc.akka.io/docs/alpakka-kafka/current ↗

docshttps://appdoc.app/artifact/com.typesafe.akka/akka-stream-kafka_2.12/ ↗