Add KafkaEmbedded.consumeFromEmbeddedTopics()
Support consuming from a subset of the embedded topics. Needed for https://github.com/spring-projects/spring-integration-kafka/issues/161
This commit is contained in:
Gary Russell
240
examples.desktop
Normal file
240
examples.desktop
Normal file
@@ -0,0 +1,240 @@
|
||||
[Desktop Entry]
|
||||
Version=1.0
|
||||
Type=Link
|
||||
Name=Examples
|
||||
Name[aa]=Ceelallo
|
||||
Name[ace]=Contoh
|
||||
Name[af]=Voorbeelde
|
||||
Name[am]=ምሳሌዎች
|
||||
Name[an]=Exemplos
|
||||
Name[ar]=أمثلة
|
||||
Name[ast]=Exemplos
|
||||
Name[az]=Nümunələr
|
||||
Name[be]=Прыклады
|
||||
Name[bg]=Примери
|
||||
Name[bn]=উদাহরণ
|
||||
Name[br]=Skouerioù
|
||||
Name[bs]=Primjeri
|
||||
Name[ca]=Exemples
|
||||
Name[ca@valencia]=Exemples
|
||||
Name[ckb]=نمونهكان
|
||||
Name[cs]=Ukázky
|
||||
Name[csb]=Przëmiôrë
|
||||
Name[cy]=Enghreifftiau
|
||||
Name[da]=Eksempler
|
||||
Name[de]=Beispiele
|
||||
Name[dv]=މިސާލުތަށް
|
||||
Name[el]=Παραδείγματα
|
||||
Name[en_AU]=Examples
|
||||
Name[en_CA]=Examples
|
||||
Name[en_GB]=Examples
|
||||
Name[eo]=Ekzemploj
|
||||
Name[es]=Ejemplos
|
||||
Name[et]=Näidised
|
||||
Name[eu]=Adibideak
|
||||
Name[fa]=نمونهها
|
||||
Name[fi]=Esimerkkejä
|
||||
Name[fil]=Mga halimbawa
|
||||
Name[fo]=Dømir
|
||||
Name[fr]=Exemples
|
||||
Name[fur]=Esemplis
|
||||
Name[fy]=Foarbylden
|
||||
Name[ga]=Samplaí
|
||||
Name[gd]=Buill-eisimpleir
|
||||
Name[gl]=Exemplos
|
||||
Name[gu]=દૃષ્ટાન્તો
|
||||
Name[gv]=Sampleyryn
|
||||
Name[he]=דוגמאות
|
||||
Name[hi]=उदाहरण
|
||||
Name[hr]=Primjeri
|
||||
Name[ht]=Egzanp
|
||||
Name[hu]=Minták
|
||||
Name[hy]=Օրինակներ
|
||||
Name[id]=Contoh
|
||||
Name[is]=Sýnishorn
|
||||
Name[it]=Esempi
|
||||
Name[ja]=サンプル
|
||||
Name[ka]=ნიმუშები
|
||||
Name[kk]=Мысалдар
|
||||
Name[kl]=Assersuutit
|
||||
Name[km]=ឧទាហរណ៍
|
||||
Name[kn]=ಉದಾಹರಣೆಗಳು
|
||||
Name[ko]=예시
|
||||
Name[ku]=Mînak
|
||||
Name[kw]=Ensamplow
|
||||
Name[ky]=Мисалдар
|
||||
Name[lb]=Beispiller
|
||||
Name[lt]=Pavyzdžių failai
|
||||
Name[lv]=Paraugi
|
||||
Name[mg]=Ohatra
|
||||
Name[mhr]=Пример-влак
|
||||
Name[mi]=Tauira
|
||||
Name[mk]=Примери
|
||||
Name[ml]=ഉദാഹരണങ്ങള്
|
||||
Name[mr]=उदाहरणे
|
||||
Name[ms]=Contoh-contoh
|
||||
Name[my]=ဥပမာများ
|
||||
Name[nb]=Eksempler
|
||||
Name[nds]=Bispelen
|
||||
Name[ne]=उदाहरणहरू
|
||||
Name[nl]=Voorbeeld-bestanden
|
||||
Name[nn]=Døme
|
||||
Name[nso]=Mehlala
|
||||
Name[oc]=Exemples
|
||||
Name[pa]=ਉਦਾਹਰਨਾਂ
|
||||
Name[pl]=Przykłady
|
||||
Name[pt]=Exemplos
|
||||
Name[pt_BR]=Exemplos
|
||||
Name[ro]=Exemple
|
||||
Name[ru]=Примеры
|
||||
Name[sc]=Esempiusu
|
||||
Name[sco]=Examples
|
||||
Name[sd]=مثالون
|
||||
Name[se]=Ovdamearkkat
|
||||
Name[shn]=တူဝ်ယၢင်ႇ
|
||||
Name[si]=නිදසුන්
|
||||
Name[sk]=Príklady
|
||||
Name[sl]=Zgledi
|
||||
Name[sml]=Saga Saupama
|
||||
Name[sn]=Miyenzaniso
|
||||
Name[sq]=Shembujt
|
||||
Name[sr]=Примери
|
||||
Name[sv]=Exempel
|
||||
Name[sw]=Mifano
|
||||
Name[szl]=Bajszpile
|
||||
Name[ta]=உதாரணங்கள்
|
||||
Name[ta_LK]=உதாரணங்கள்
|
||||
Name[te]=ఉదాహరణలు
|
||||
Name[tg]=Намунаҳо
|
||||
Name[th]=ตัวอย่าง
|
||||
Name[tr]=Örnekler
|
||||
Name[tt]=Мисаллар
|
||||
Name[ug]=مىساللار
|
||||
Name[uk]=Приклади
|
||||
Name[ur]=مثالیں
|
||||
Name[uz]=Намуналар
|
||||
Name[vec]=Esempi
|
||||
Name[vi]=Mẫu ví dụ
|
||||
Name[wae]=Bischbil
|
||||
Name[zh_CN]=示例
|
||||
Name[zh_HK]=範例
|
||||
Name[zh_TW]=範例
|
||||
Comment=Example content for Ubuntu
|
||||
Comment[aa]=Ubuntuh addattinoh ceelallo
|
||||
Comment[ace]=Contoh aso ke Ubuntu
|
||||
Comment[af]=Voorbeeld inhoud vir Ubuntu
|
||||
Comment[am]=ዝርዝር ምሳሌዎች ለ ኡቡንቱ
|
||||
Comment[an]=Conteniu d'exemplo ta Ubuntu
|
||||
Comment[ar]=أمثلة محتوى لأوبونتو
|
||||
Comment[ast]=Conteníu del exemplu pa Ubuntu
|
||||
Comment[az]=Ubuntu üçün nümunə material
|
||||
Comment[be]=Узоры дакументаў для Ubuntu
|
||||
Comment[bg]=Примерно съдържание за Ubuntu
|
||||
Comment[bn]=উবুন্টু সংক্রান্ত নমুনা তথ্য
|
||||
Comment[br]=Skouerenn endalc'had evit Ubuntu
|
||||
Comment[bs]=Primjer sadrzaja za Ubuntu
|
||||
Comment[ca]=Continguts d'exemple per a l'Ubuntu
|
||||
Comment[ca@valencia]=Continguts d'exemple per a l'Ubuntu
|
||||
Comment[ckb]=نموونەی ناوەڕۆکێک بۆ ئوبوونتو
|
||||
Comment[cs]=Ukázkový obsah pro Ubuntu
|
||||
Comment[csb]=Przëmiôrowô zamkłosc dlô Ubuntu
|
||||
Comment[cy]=Cynnwys enghraifft ar gyfer Ubuntu
|
||||
Comment[da]=Eksempel indhold til Ubuntu
|
||||
Comment[de]=Beispielinhalt für Ubuntu
|
||||
Comment[dv]=އުބުންޓު އާއި އެކަށޭނަ މިސާލުތައް
|
||||
Comment[el]=Παραδείγματα περιεχομένου για το Ubuntu
|
||||
Comment[en_AU]=Example content for Ubuntu
|
||||
Comment[en_CA]=Example content for Ubuntu
|
||||
Comment[en_GB]=Example content for Ubuntu
|
||||
Comment[eo]=Ekzempla enhavo por Ubuntu
|
||||
Comment[es]=Contenido de ejemplo para Ubuntu
|
||||
Comment[et]=Ubuntu näidisfailid
|
||||
Comment[eu]=Adibidezko edukia Ubunturako
|
||||
Comment[fa]=محتویات نمونه برای اوبونتو
|
||||
Comment[fi]=Esimerkkisisältöjä Ubuntulle
|
||||
Comment[fil]=Halimbawang laman para sa Ubuntu
|
||||
Comment[fo]=Dømis innihald fyri Ubuntu
|
||||
Comment[fr]=Contenu d'exemple pour Ubuntu
|
||||
Comment[fur]=Contignûts di esempli par Ubuntu
|
||||
Comment[fy]=Foarbyld fan ynhâld foar Ubuntu
|
||||
Comment[ga]=Inneachar samplach do Ubuntu
|
||||
Comment[gd]=Eisimpleir de shusbaint airson Ubuntu
|
||||
Comment[gl]=Contido do exemplo para Ubuntu
|
||||
Comment[gu]=Ubuntu માટે ઉદાહરણ સૂચી
|
||||
Comment[gv]=Stoo Sanpleyr son Ubuntu
|
||||
Comment[he]=תוכן לדוגמה עבור אובונטו
|
||||
Comment[hi]=उबुन्टू हेतु उदाहरण सारांश
|
||||
Comment[hr]=Primjeri sadržaja za Ubuntu
|
||||
Comment[ht]=Kontni egzanplè pou Ubuntu
|
||||
Comment[hu]=Mintatartalom Ubuntuhoz
|
||||
Comment[hy]=Բովանդակության օրինակները Ubuntu֊ի համար
|
||||
Comment[id]=Contoh isi bagi Ubuntu
|
||||
Comment[is]=Sýnishorn fyrir Ubuntu
|
||||
Comment[it]=Contenuti di esempio per Ubuntu
|
||||
Comment[ja]=Ubuntuのサンプルコンテンツ
|
||||
Comment[ka]=უბუნტუს სანიმუშო შიგთავსი
|
||||
Comment[kk]=Ubuntu құжаттар мысалдары
|
||||
Comment[kl]=Ubuntu-mut imarisaanut assersuut
|
||||
Comment[km]=ឧទាហរណ៍សម្រាប់អាប់ប៊ុនធូ
|
||||
Comment[kn]=ಉಬುಂಟುಗೆ ಉದಾಹರಣೆಗಳು
|
||||
Comment[ko]=우분투 컨텐츠 예시
|
||||
Comment[ku]=Ji bo Ubuntu mînaka naverokê
|
||||
Comment[ky]=Ubuntu-нун мисал документтери
|
||||
Comment[lb]=Beispillinhalt fir Ubuntu
|
||||
Comment[lt]=Įvairių dokumentų, paveikslėlių, garsų bei vaizdų pavyzdžiai
|
||||
Comment[lv]=Parauga saturs Ubuntu videi
|
||||
Comment[mg]=Ohatra ho an'i Ubuntu
|
||||
Comment[mhr]=Ubuntu-лан документ-влакын пример-влак
|
||||
Comment[mi]=Mata tauira o Ubuntu
|
||||
Comment[mk]=Пример содржина за Убунту
|
||||
Comment[ml]=ഉബുണ്ടുവിനു വേണ്ടിയുള്ള ഉദാഹരണങ്ങള്
|
||||
Comment[mr]=उबंटूसाठी घटकांची उदाहरणे
|
||||
Comment[ms]=Kandungan contoh untuk Ubuntu
|
||||
Comment[my]=Ubuntu အတွက် နမူနာ မာတိကာ
|
||||
Comment[nb]=Eksempelinnhold for Ubuntu
|
||||
Comment[ne]=उबन्टुका लागि उदाहरण सामग्री
|
||||
Comment[nl]=Voorbeeldinhoud voor Ubuntu
|
||||
Comment[nn]=Eksempelinnhald for Ubuntu
|
||||
Comment[nso]=Mohlala wa dikagare tša Ubuntu
|
||||
Comment[oc]=Exemples de contengut per Ubuntu
|
||||
Comment[pa]=ਉਬਤੂੰ ਲਈ ਨਮੂਨਾ ਸਮੱਗਰੀ
|
||||
Comment[pl]=Przykładowa zawartość dla Ubuntu
|
||||
Comment[pt]=Conteúdo de exemplo para o Ubuntu
|
||||
Comment[pt_BR]=Exemplo de conteúdo para Ubuntu
|
||||
Comment[ro]=Conținut exemplu pentru Ubuntu
|
||||
Comment[ru]=Примеры документов для Ubuntu
|
||||
Comment[sc]=Esempiu de cabidu pro Ubuntu
|
||||
Comment[sco]=Example content fur Ubuntu
|
||||
Comment[sd]=اوبنٽو لاءِ مثال طور ڏنل مواد
|
||||
Comment[shn]=တူဝ်ႇယၢင်ႇလမ်းၼႂ်း တႃႇ Ubuntu
|
||||
Comment[si]=උබුන්ටු සඳහා උදාහරණ අන්තර්ගතයන්
|
||||
Comment[sk]=Ukážkový obsah pre Ubuntu
|
||||
Comment[sl]=Ponazoritvena vsebina za Ubuntu
|
||||
Comment[sml]=Saupama Isina Ubuntu
|
||||
Comment[sn]=Muyenzaniso wehuiswa kuitira Ubuntu
|
||||
Comment[sq]=Shembull i përmbajtjes për Ubuntu
|
||||
Comment[sr]=Садржај примера за Убунту
|
||||
Comment[sv]=Exempelinnehåll för Ubuntu
|
||||
Comment[sw]=Bidhaa mfano ya Ubuntu
|
||||
Comment[szl]=Bajszpilnŏ treść dlŏ Ubuntu
|
||||
Comment[ta]=உபுண்டுவிற்கான எடுத்துகாட்டு உள்ளடக்கங்கள்
|
||||
Comment[ta_LK]=உபுண்டுவிற்கான எடுத்துகாட்டு உள்ளடக்கங்கள்
|
||||
Comment[te]=Ubuntu వాడుక విధాన నమూనాలు
|
||||
Comment[tg]=Мӯҳтавои намунавӣ барои Ubuntu
|
||||
Comment[th]=ตัวอย่างข้อมูลสำหรับ Ubuntu
|
||||
Comment[tr]=Ubuntu için örnek içerik
|
||||
Comment[tt]=Ubuntu өчен документ мисаллары
|
||||
Comment[ug]=ئۇبۇنتۇنىڭ مىساللىرى
|
||||
Comment[uk]=Приклади контенту для Ubuntu
|
||||
Comment[ur]=یوبنٹو کیلئے مثالی مواد
|
||||
Comment[uz]=Ubuntu учун намуна таркиби
|
||||
Comment[vec]=Contenuti de esempio de Ubuntu
|
||||
Comment[vi]=Mẫu ví dụ cho Ubuntu
|
||||
Comment[wae]=D'Ubuntu bischbildatijä
|
||||
Comment[zh_CN]=Ubuntu 示例内容
|
||||
Comment[zh_HK]=Ubuntu 的範例內容
|
||||
Comment[zh_TW]=Ubuntu 的範例內容
|
||||
URL=file:///usr/share/example-content/
|
||||
Icon=folder
|
||||
X-Ubuntu-Gettext-Domain=example-content
|
||||
|
||||
@@ -397,9 +397,21 @@ public class KafkaEmbedded extends ExternalResource implements KafkaRule {
|
||||
* @throws Exception an exception.
|
||||
*/
|
||||
public void consumeFromAnEmbeddedTopic(Consumer<?, ?> consumer, String topic) throws Exception {
|
||||
assertThat(this.topics).as("topic is not in embedded topic list").contains(topic);
|
||||
consumeFromEmbeddedTopics(consumer, topic);
|
||||
}
|
||||
|
||||
/**
|
||||
* Subscribe a consumer to one or more of the embedded topics.
|
||||
* @param consumer the consumer.
|
||||
* @param topics the topics.
|
||||
* @throws Exception an exception.
|
||||
*/
|
||||
public void consumeFromEmbeddedTopics(Consumer<?, ?> consumer, String... topics) throws Exception {
|
||||
for (String topic : topics) {
|
||||
assertThat(this.topics).as("topic '" + topic + "' is not in embedded topic list").contains(topic);
|
||||
}
|
||||
final CountDownLatch consumerLatch = new CountDownLatch(1);
|
||||
consumer.subscribe(Collections.singletonList(topic), new ConsumerRebalanceListener() {
|
||||
consumer.subscribe(Arrays.asList(topics), new ConsumerRebalanceListener() {
|
||||
|
||||
@Override
|
||||
public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
|
||||
|
||||
Reference in New Issue
Block a user